Skip to content

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