ConsumerCoordinator¶

ConsumerCoordinator is a consumer group coordination manager.

Creating Instance¶

ConsumerCoordinator takes the following to be created:

• GroupRebalanceConfig
• LogContext
• ConsumerNetworkClient
• ConsumerPartitionAssignors
• ConsumerMetadata
• SubscriptionState
• Metrics
• Metrics Group Prefix
• Time
• autoCommitEnabled
• auto.commit.interval.ms
• ConsumerInterceptors
• internal.throw.on.fetch.stable.offset.unsupported

While being created, ConsumerCoordinator requests the ConsumerMetadata for an update of the current cluster metadata.

ConsumerCoordinator is created when:

• KafkaConsumer is created (and group.id configuration property is specified)

autoCommitEnabled¶

ConsumerCoordinator is given autoCommitEnabled flag when created with the value based on group.id and enable.auto.commit configuration properties.

metadata¶

JoinGroupRequestData.JoinGroupRequestProtocolCollection metadata()

metadata...FIXME

metadata is part of the AbstractCoordinator abstraction.