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

使用ExecutorConsumerProperties的程序包

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

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

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

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

参数类型为ExecutorConsumerProperties的io.github.wooenrico.kafka中的方法

修饰符和类型	方法	说明
static ThreadPoolExecutor	KafkaUtil.newThreadPoolExecutor(String name, ExecutorConsumerProperties consumerProperties)

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

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

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

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

限定符	构造器	说明
	AbstractExecutorKafkaConsumer(String name, ExecutorConsumerProperties consumerProperties, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)
	AbstractExecutorKafkaReceiver(String name, ExecutorConsumerProperties 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)