Package org.apache.kafka.clients.producer.internals

Class RecordAccumulator.NodeLatencyStats

java.lang.Object

org.apache.kafka.clients.producer.internals.RecordAccumulator.NodeLatencyStats

Enclosing class:

RecordAccumulator

public static final class RecordAccumulator.NodeLatencyStats
extends Object

Node latency stats for each node that are used for adaptive partition distribution Visible for testing

Field Summary

Fields

Modifier and Type	Field	Description
long	drainTimeMs
long	readyTimeMs

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

readyTimeMs

public volatile long readyTimeMs

drainTimeMs

public volatile long drainTimeMs