public static class PartitionGroup.RecordInfo
extends java.lang.Object
Constructor and Description |
---|
RecordInfo() |
Modifier and Type | Method and Description |
---|---|
ProcessorNode |
node() |
org.apache.kafka.common.TopicPartition |
partition() |
public ProcessorNode node()
public org.apache.kafka.common.TopicPartition partition()