public static class KafkaSubscriber.PartitionChange extends Object
Modifier and Type | Method and Description |
---|---|
Set<org.apache.kafka.common.TopicPartition> |
getNewPartitions() |
Set<org.apache.kafka.common.TopicPartition> |
getRemovedPartitions() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.