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

类 ReactorKafkaSender<K,V,T>

java.lang.Object
io.github.wooenrico.kafka.sender.ReactorKafkaSender<K,V,T>
所有已实现的接口:
Closeable, AutoCloseable
直接已知子类:
ProducerRecordReactorKafkaSender
public abstract class ReactorKafkaSender<K,V,T> extends Object implements Closeable

  • 字段概要

    字段
    修饰符和类型
    字段
    说明
    protected final org.apache.kafka.common.serialization.Serializer<K>
    keySerializer
     
    protected final SenderProperties
    properties
     
    protected final org.apache.kafka.common.serialization.Serializer<V>
    valueSerializer
     

  • 构造器概要

    构造器
    构造器
    说明
    ReactorKafkaSender(SenderProperties properties, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
     
    ReactorKafkaSender(SenderProperties properties, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer, Consumer<reactor.kafka.sender.SenderResult<T>> senderResultConsumer)
     

  • 方法概要

    修饰符和类型
    方法
    说明
    void
    close()
     
    reactor.core.publisher.Mono<Void>
    send(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, T object)
    提交队列失败，直接写入
    reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>>
    send(org.reactivestreams.Publisher<reactor.kafka.sender.SenderRecord<K,V,T>> senderRecord)
    kafka 直接写入
    reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>>
    send(reactor.kafka.sender.SenderRecord<K,V,T> senderRecord)
    kafka 直接写入

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

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

  • 字段详细资料

    • properties

      protected final SenderProperties properties

    • keySerializer

      protected final org.apache.kafka.common.serialization.Serializer<K> keySerializer

    • valueSerializer

      protected final org.apache.kafka.common.serialization.Serializer<V> valueSerializer

  • 构造器详细资料

    • ReactorKafkaSender

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

    • ReactorKafkaSender

      public ReactorKafkaSender(SenderProperties properties, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer, Consumer<reactor.kafka.sender.SenderResult<T>> senderResultConsumer)

  • 方法详细资料

    • close

      public void close()
      指定者:
      close 在接口中 AutoCloseable
      指定者:
      close 在接口中 Closeable

    • send

      public reactor.core.publisher.Mono<Void> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, T object)
      提交队列失败，直接写入
      参数:
      producerRecord - 生产者记录
      object - 返回数据
      返回:
      提交结果

    • send

      public reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> send(reactor.kafka.sender.SenderRecord<K,V,T> senderRecord)
      kafka 直接写入
      参数:
      senderRecord - 发送记录
      返回:
      发送结果

    • send

      public reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> send(org.reactivestreams.Publisher<reactor.kafka.sender.SenderRecord<K,V,T>> senderRecord)
      kafka 直接写入
      参数:
      senderRecord - 发送记录
      返回:
      发送结果