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

类 AbstractRateLimitExecutorKafkaConsumer<K,V>

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<K,V>

所有已实现的接口:

Closeable, AutoCloseable

直接已知子类:

DefaultKafkaConsumer

public abstract class AbstractRateLimitExecutorKafkaConsumer<K,V>
extends AbstractExecutorKafkaConsumer<K,V>

字段概要

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

consumerProperties, keyDeserializer, name, valueDeserializer

构造器概要

构造器

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

方法概要

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

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

close, handle

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

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

构造器详细资料

AbstractRateLimitExecutorKafkaConsumer

public 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)

方法详细资料

executorHandle

protected void executorHandle(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)

指定者:

executorHandle 在类中 AbstractExecutorKafkaConsumer<K,V>

rateLimitHandle

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