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

public abstract class AbstractRateLimitExecutorKafkaReceiver<K,V> extends AbstractExecutorKafkaReceiver<K,V>

字段概要

从类继承的字段 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver
consumerProperties, keyDeserializer, name, onAssign, onRevoke, valueDeserializer
构造器概要

构造器

构造器

说明

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)
方法概要

修饰符和类型

方法

说明

protected reactor.core.publisher.Mono<Void>

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

protected abstract reactor.core.publisher.Mono<Void>

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

从类继承的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaReceiver
close, handle

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料
- AbstractRateLimitExecutorKafkaReceiver
  
  public 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)
方法详细资料
- executorHandle
  
  protected reactor.core.publisher.Mono<Void> executorHandle(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
  
  指定者:
  
  executorHandle 在类中 AbstractExecutorKafkaReceiver<K,V>
- rateLimitHandle
  
  protected abstract reactor.core.publisher.Mono<Void> rateLimitHandle(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)

类 AbstractRateLimitExecutorKafkaReceiver<K,V>

字段概要