类 ProducerRecordReactorKafkaSender<K,V>

java.lang.Object
io.github.wooenrico.kafka.sender.ReactorKafkaSender<K,V,org.apache.kafka.clients.producer.ProducerRecord<K,V>>
io.github.wooenrico.kafka.sender.ProducerRecordReactorKafkaSender<K,V>
所有已实现的接口:
Closeable, AutoCloseable
直接已知子类:
DefaultReactorKafkaSender

public abstract class ProducerRecordReactorKafkaSender<K,V> extends ReactorKafkaSender<K,V,org.apache.kafka.clients.producer.ProducerRecord<K,V>>
  • 构造器详细资料

    • ProducerRecordReactorKafkaSender

      public ProducerRecordReactorKafkaSender(SenderProperties properties, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
    • ProducerRecordReactorKafkaSender

      public ProducerRecordReactorKafkaSender(SenderProperties properties, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer, Consumer<reactor.kafka.sender.SenderResult<org.apache.kafka.clients.producer.ProducerRecord<K,V>>> senderResultConsumer)
  • 方法详细资料

    • send

      public reactor.core.publisher.Mono<Void> send(String topic, V value)
      参数:
      topic - 主题topic
      value - 数据
      返回:
      Mono
    • send

      public reactor.core.publisher.Mono<Void> send(String topic, K key, V value)
      参数:
      topic - 主题topic
      key - 分区key
      value - 数据
      返回:
      Mono
    • send

      public reactor.core.publisher.Mono<Void> send(String topic, Integer partition, K key, V value)
      参数:
      topic - 主题topic
      partition - 分区ID
      key - 分区key
      value - 数据
      返回:
      Mono
    • send

      public reactor.core.publisher.Mono<Void> send(String topic, Integer partition, Long timestamp, K key, V value)
      参数:
      topic - 主题topic
      partition - 分区ID
      timestamp - 时间戳
      key - 分区key
      value - 数据
      返回:
      Mono