@Immutable public final class SuspendedTopicPartition extends AbstractTopicPartitionHistory
SuspendedTopicPartition
models the TopicPartition
that should be suspended for reassignments. It acts
as a delayed notification to signal when it is OK to move this partition again.Constructor and Description |
---|
SuspendedTopicPartition(org.apache.kafka.common.TopicPartition tp,
long suspensionDurationMs,
long epoch)
Creates a
SuspendedTopicPartition with provided topic partition and the suspension duration in
milliseconds. |
Modifier and Type | Method and Description |
---|---|
String |
toString() |
deadlineMs, epoch, topicPartition, untilDeadline
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
compareTo
public SuspendedTopicPartition(org.apache.kafka.common.TopicPartition tp, long suspensionDurationMs, long epoch)
SuspendedTopicPartition
with provided topic partition and the suspension duration in
milliseconds.