public interface TaskTopicPartition
Modifier and Type | Method and Description |
---|---|
boolean |
isChangelog() |
boolean |
isSource() |
Optional<Set<String>> |
rackIds() |
org.apache.kafka.common.TopicPartition |
topicPartition() |
org.apache.kafka.common.TopicPartition topicPartition()
TopicPartition
for this task.boolean isSource()
boolean isChangelog()