类的使用
io.github.wooenrico.kafka.consumer.ConsumerProperties

使用ConsumerProperties的程序包

程序包	说明
io.github.wooenrico.kafka
io.github.wooenrico.kafka.consumer

io.github.wooenrico.kafka中ConsumerProperties的使用

io.github.wooenrico.kafka中ConsumerProperties的子类

修饰符和类型	类	说明
class	BeanNameRateLimitExecutorConsumerProperties	指定handler bean name的速率限制线程池消费者配置

io.github.wooenrico.kafka.consumer中ConsumerProperties的使用

io.github.wooenrico.kafka.consumer中ConsumerProperties的子类

修饰符和类型	类	说明
class	ExecutorConsumerProperties	线程池消费者配置
class	RateLimitExecutorConsumerProperties	速率限制线程池消费者配置

声明为ConsumerProperties的io.github.wooenrico.kafka.consumer中的字段

修饰符和类型	字段	说明
protected final ConsumerProperties	AbstractKafkaConsumer.consumerProperties
protected final ConsumerProperties	AbstractKafkaReceiver.consumerProperties

参数类型为ConsumerProperties的io.github.wooenrico.kafka.consumer中的构造器

限定符	构造器	说明
	AbstractKafkaConsumer(String name, ConsumerProperties consumerProperties, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)
	AbstractKafkaReceiver(String name, ConsumerProperties consumerProperties, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer, Consumer<Collection<reactor.kafka.receiver.ReceiverPartition>> onAssign, Consumer<Collection<reactor.kafka.receiver.ReceiverPartition>> onRevoke)