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

类 DefaultKafkaConsumer

java.lang.Object

io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer<K,V>

io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaConsumer<K,V>

io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaConsumer<String,String>

io.github.wooenrico.kafka.consumer.DefaultKafkaConsumer

所有已实现的接口:

Closeable, AutoCloseable

public class DefaultKafkaConsumer
extends AbstractRateLimitExecutorKafkaConsumer<String,String>

字段概要

从类继承的字段 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

consumerProperties, keyDeserializer, name, valueDeserializer

构造器概要

构造器

构造器	说明
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)

方法概要

修饰符和类型	方法	说明
protected void	rateLimitHandle(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)

从类继承的方法 io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaConsumer

executorHandle

从类继承的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaConsumer

close, handle

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DefaultKafkaConsumer

public DefaultKafkaConsumer(String name,
 RateLimitExecutorConsumerProperties consumerProperties,
 Consumer<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> consumer)

DefaultKafkaConsumer

public DefaultKafkaConsumer(String name,
 RateLimitExecutorConsumerProperties consumerProperties,
 Consumer<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> consumer,
 org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)

方法详细资料

rateLimitHandle

protected void rateLimitHandle(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)

指定者:

rateLimitHandle 在类中 AbstractRateLimitExecutorKafkaConsumer<String,String>