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

类 KafkaProducer<K,V>

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

  • 字段概要

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

  • 构造器概要

    构造器
    构造器
    说明
    KafkaProducer(Properties properties, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
     

  • 方法概要

    修饰符和类型
    方法
    说明
    void
    close()
     
    Future<org.apache.kafka.clients.producer.RecordMetadata>
    send(String topic, Integer partition, Long timestamp, K key, V value)
     
    void
    send(String topic, Integer partition, Long timestamp, K key, V value, org.apache.kafka.clients.producer.Callback callback)
     
    Future<org.apache.kafka.clients.producer.RecordMetadata>
    send(String topic, Integer partition, K key, V value)
     
    void
    send(String topic, Integer partition, K key, V value, org.apache.kafka.clients.producer.Callback callback)
     
    Future<org.apache.kafka.clients.producer.RecordMetadata>
    send(String topic, K key, V value)
     
    void
    send(String topic, K key, V value, org.apache.kafka.clients.producer.Callback callback)
     
    Future<org.apache.kafka.clients.producer.RecordMetadata>
    send(String topic, V value)
     
    void
    send(String topic, V value, org.apache.kafka.clients.producer.Callback callback)
     
    Future<org.apache.kafka.clients.producer.RecordMetadata>
    send(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord)
     
    void
    send(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.Callback callback)
     

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

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

  • 字段详细资料

    • properties

      protected final Properties properties

    • keySerializer

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

    • valueSerializer

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

  • 构造器详细资料

    • KafkaProducer

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

  • 方法详细资料

    • close

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

    • send

      public Future<org.apache.kafka.clients.producer.RecordMetadata> send(String topic, V value)
      参数:
      topic - 主题topic
      value - 数据
      返回:
      提交结果

    • send

      public Future<org.apache.kafka.clients.producer.RecordMetadata> send(String topic, K key, V value)
      参数:
      topic - 主题topic
      key - 分区key
      value - 数据
      返回:
      提交结果

    • send

      public Future<org.apache.kafka.clients.producer.RecordMetadata> send(String topic, Integer partition, K key, V value)
      参数:
      topic - 主题topic
      partition - 分区ID
      key - 分区key
      value - 数据
      返回:
      提交结果

    • send

      public Future<org.apache.kafka.clients.producer.RecordMetadata> send(String topic, Integer partition, Long timestamp, K key, V value)
      参数:
      topic - 主题topic
      partition - 分区ID
      timestamp - 时间戳
      key - 分区key
      value - 数据
      返回:
      提交结果

    • send

      public Future<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord)
      参数:
      producerRecord - 生产者记录
      返回:
      提交结果

    • send

      public void send(String topic, V value, org.apache.kafka.clients.producer.Callback callback)
      参数:
      topic - 主题topic
      value - 数据
      callback - 回调

    • send

      public void send(String topic, K key, V value, org.apache.kafka.clients.producer.Callback callback)
      参数:
      topic - 主题topic
      key - 分区key
      value - 数据
      callback - 回调

    • send

      public void send(String topic, Integer partition, K key, V value, org.apache.kafka.clients.producer.Callback callback)
      参数:
      topic - 主题topic
      partition - 分区ID
      key - 分区key
      value - 数据
      callback - 回调

    • send

      public void send(String topic, Integer partition, Long timestamp, K key, V value, org.apache.kafka.clients.producer.Callback callback)
      参数:
      topic - 主题topic
      partition - 分区ID
      timestamp - 时间戳
      key - 分区key
      value - 数据
      callback - 回调

    • send

      public void send(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.Callback callback)
      参数:
      producerRecord - 生产者记录
      callback - 回调