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

Class RecordAccumulator.ReadyCheckResult

java.lang.Object

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

Enclosing class:

RecordAccumulator

public static final class RecordAccumulator.ReadyCheckResult
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final long	nextReadyCheckDelayMs
final Set<org.apache.kafka.common.Node>	readyNodes
final Set<String>	unknownLeaderTopics

Constructor Summary

Constructors

Constructor	Description
ReadyCheckResult(Set<org.apache.kafka.common.Node> readyNodes, long nextReadyCheckDelayMs, Set<String> unknownLeaderTopics)

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

readyNodes

public final Set<org.apache.kafka.common.Node> readyNodes

nextReadyCheckDelayMs

public final long nextReadyCheckDelayMs

unknownLeaderTopics

public final Set<String> unknownLeaderTopics

Constructor Details

ReadyCheckResult

public ReadyCheckResult(Set<org.apache.kafka.common.Node> readyNodes,
 long nextReadyCheckDelayMs,
 Set<String> unknownLeaderTopics)