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

使用RateLimitExecutorConsumerProperties的程序包

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

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

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

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

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

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

限定符	构造器	说明
	AbstractRateLimitExecutorKafkaConsumer(String name, RateLimitExecutorConsumerProperties consumerProperties, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)
	AbstractRateLimitExecutorKafkaReceiver(String name, RateLimitExecutorConsumerProperties 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)
	DefaultKafkaConsumer(String name, RateLimitExecutorConsumerProperties consumerProperties, Consumer<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> consumer)
	DefaultKafkaConsumer(String name, RateLimitExecutorConsumerProperties consumerProperties, Consumer<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)
	DefaultKafkaReceiver(String name, RateLimitExecutorConsumerProperties consumerProperties, Function<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>,reactor.core.publisher.Mono<Void>> consumer)
	DefaultKafkaReceiver(String name, RateLimitExecutorConsumerProperties consumerProperties, Function<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>,reactor.core.publisher.Mono<Void>> consumer, Consumer<Collection<reactor.kafka.receiver.ReceiverPartition>> onAssign, Consumer<Collection<reactor.kafka.receiver.ReceiverPartition>> onRevoke)