Interface Producer<K,V>

Method Details

• initTransactions

  void initTransactions()

  See KafkaProducer.initTransactions()

• beginTransaction

  void beginTransaction() throws ProducerFencedException

  See KafkaProducer.beginTransaction()

  Throws:

  ProducerFencedException

• sendOffsetsToTransaction

  void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, ConsumerGroupMetadata groupMetadata) throws ProducerFencedException

  See KafkaProducer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata)

  Throws:

  ProducerFencedException

• commitTransaction

  void commitTransaction() throws ProducerFencedException

  See KafkaProducer.commitTransaction()

  Throws:

  ProducerFencedException

• abortTransaction

  void abortTransaction() throws ProducerFencedException

  See KafkaProducer.abortTransaction()

  Throws:

  ProducerFencedException

• registerMetricForSubscription

  void registerMetricForSubscription(KafkaMetric metric)

  See Also:

  • KafkaProducer.registerMetricForSubscription(KafkaMetric)

• unregisterMetricFromSubscription

  void unregisterMetricFromSubscription(KafkaMetric metric)

  See Also:

  • KafkaProducer.unregisterMetricFromSubscription(KafkaMetric)

• send

  Future<RecordMetadata> send(ProducerRecord<K,V> record)

  See KafkaProducer.send(ProducerRecord)

• send

  Future<RecordMetadata> send(ProducerRecord<K,V> record, Callback callback)

  See KafkaProducer.send(ProducerRecord, Callback)

• flush

  void flush()

  See KafkaProducer.flush()

• partitionsFor

  List<PartitionInfo> partitionsFor(String topic)

  See KafkaProducer.partitionsFor(String)

• metrics

  Map<MetricName, ? extends Metric> metrics()

  See KafkaProducer.metrics()

• clientInstanceId

  Uuid clientInstanceId(Duration timeout)

  See KafkaProducer.clientInstanceId(Duration)}

• close

  void close()

  See KafkaProducer.close()

  Specified by:

  close in interface AutoCloseable

  Specified by:

  close in interface Closeable

• close

  void close(Duration timeout)

  See KafkaProducer.close(Duration)