BufferPool¶

BufferPool is created alongsize KafkaProducer for the RecordAccumulator.

Creating Instance¶

BufferPool takes the following to be created:

• Total Memory Size
• Batch Size
• Metrics
• Time
• Metric Group Name

BufferPool is created when:

• KafkaProducer is created (to create a RecordAccumulator)

Total Memory Size¶

BufferPool is given the total memory size when created.

The size is by default the value of buffer.memory configuration property.

Batch Size¶

BufferPool is given the batch size when created.

The size is by default the value of batch.size configuration property.

Metrics¶

BufferPool registers the metrics under the producer-metrics group name.

buffer-exhausted-rate¶

The average per-second number of record sends that are dropped due to buffer exhaustion

buffer-exhausted-records¶

buffer-exhausted-total¶

The total number of record sends that are dropped due to buffer exhaustion

bufferpool-wait-ratio¶

The fraction of time an appender waits for space allocation

bufferpool-wait-time-ns-total¶

The total time (in ns) an appender waits for space allocation