Uses of Class
org.apache.flink.connector.kafka.source.enumerator.subscriber.KafkaSubscriber.PartitionChange

Packages that use KafkaSubscriber.PartitionChange

Package	Description
org.apache.flink.connector.kafka.source.enumerator.subscriber

Uses of KafkaSubscriber.PartitionChange in org.apache.flink.connector.kafka.source.enumerator.subscriber

Methods in org.apache.flink.connector.kafka.source.enumerator.subscriber that return KafkaSubscriber.PartitionChange

Modifier and Type	Method and Description
KafkaSubscriber.PartitionChange	KafkaSubscriber.getPartitionChanges(org.apache.kafka.clients.admin.AdminClient adminClient, Set<org.apache.kafka.common.TopicPartition> currentAssignment) Get the partitions changes compared to the current partition assignment.