Producer¶

Producer<K, V> is an interface to KafkaProducer for Kafka developers to use to send records (with K keys and V values) to a Kafka cluster.

Contract (Subset)¶

abortTransaction¶

void abortTransaction()

beginTransaction¶

void beginTransaction()

commitTransaction¶

void commitTransaction()

initTransactions¶

void initTransactions()

sendOffsetsToTransaction¶

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

Used when the producer is also a Consumer for a consume-transform-produce pattern