Package org.apache.kafka.clients.producer
-
Interface Summary Interface Description Callback A callback interface that the user can implement to allow code to execute when the request is complete.Partitioner Partitioner Interface is not supported.Producer<K,V> The interface for theKafkaProducer
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.StreamsPartitioner Partitioner Interface -
Class Summary Class Description DefaultStreamsPartitioner KafkaProducer<K,V> A Kafka client that publishes records to the Kafka cluster.MockProducer<K,V> This class is not supported.ProducerConfig Configuration for the Kafka Producer.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 -
Exception Summary Exception Description BufferExhaustedException 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.