Package org.apache.kafka.clients.producer.internals
package org.apache.kafka.clients.producer.internals
-
ClassDescriptionA pool of ByteBuffers kept under a given memory limit.Built-in default partitioner.Info for the current sticky partition.Deprecated.The future result of a record sendA batch of records that is or will be sent.A class that models the future completion of a produce request for a single partition.ProducerInterceptors<K,
V> A container that holds the listProducerInterceptorand wraps calls to the chain of custom interceptors.This class acts as a queue that accumulates records intoMemoryRecordsinstances to be sent to the server.Node latency stats for each node that are used for adaptive partition distribution Visible for testingPartitioner config for built-in partitionerThe background thread that handles the sending of produce requests to the Kafka cluster.An internal class that implements a cache used for sticky partitioning behavior.A class which maintains state for transactions.