Package org.apache.kafka.clients.producer
package org.apache.kafka.clients.producer
-
ClassDescriptionThis exception is thrown if the producer cannot allocate memory for a record within max.block.ms due to the buffer being too full.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 InterfaceProducer<K,V> The interface for theKafkaProducer
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.The metadata for a record that has been acknowledged by the serverThe "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.