A callback interface that the user can implement to allow code to execute when the request is complete.
The interface for the
A plugin interface that allows you to intercept (and possibly mutate) the records received by the producer before they are published to the Kafka cluster.
A Kafka client that publishes records to the Kafka cluster.
A mock of the producer interface you can use for testing code that uses Kafka.
Configuration for the Kafka Producer.
A key/value pair to be sent to Kafka.
The metadata for a record that has been acknowledged by the server
The "Round-Robin" partitioner This partitioning strategy can be used when user wants to distribute the writes to all partitions equally.
The partitioning strategy: If a partition is specified in the record, use it Otherwise choose the sticky partition that changes when the batch is full.
This exception is thrown if the producer is in non-blocking mode and the rate of data production exceeds the rate at which data can be sent for long enough for the allocated buffer to be exhausted.