SubscriptionState

SubscriptionState allows for tracking the topics, partitions, and offsets assigned to a Kafka consumer.

SubscriptionState is in partitionsAutoAssigned if it is AUTO_TOPICS or AUTO_PATTERN.

Table 1. SubscriptionState’s Internal Properties (e.g. Registries, Counters and Flags)
Name Description

listener

ConsumerRebalanceListener for notifications about partition assignment changes

Used exclusively when ConsumerCoordinator is notified about:

groupSubscription

subscribe Method

void subscribe(Pattern pattern, ConsumerRebalanceListener listener)

subscribe…​FIXME

Note
 subscribe is used exclusively when KafkaConsumer is requested to subscribe to the topics that match a pattern with a ConsumerRebalanceListener.

Adding Topics to Group Subscription — groupSubscribe Method

void groupSubscribe(Collection<String> topics)

groupSubscribe…​FIXME

Note
 groupSubscribe is used when…​FIXME

results matching ""

    No results matching ""