Package org.apache.kafka.clients.producer

package org.apache.kafka.clients.producer

Provides a Kafka client for producing records to topics and/or partitions in a Kafka cluster.

Class	Description
BufferExhaustedException	This exception is thrown if the producer cannot allocate memory for a record within max.block.ms due to the buffer being too full.
Callback	A callback interface that the user can implement to allow code to execute when the request is complete.
KafkaProducer<K,V>	A Kafka client that publishes records to the Kafka cluster.
MockProducer<K,V>	A mock of the producer interface you can use for testing code that uses Kafka.
Partitioner	Partitioner Interface
Producer<K,V>	The interface for the KafkaProducer
ProducerConfig	Configuration for the Kafka Producer.
ProducerInterceptor<K,V>	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.
ProducerRecord<K,V>	A key/value pair to be sent to Kafka.
RecordMetadata	The metadata for a record that has been acknowledged by the server
RoundRobinPartitioner	The "Round-Robin" partitioner This partitioning strategy can be used when user wants to distribute the writes to all partitions equally.
UniformStickyPartitioner	Deprecated.