Skip to content

ConsumerCoordinator

ConsumerCoordinator is a consumer group coordination manager.

Creating Instance

ConsumerCoordinator takes the following to be created:

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.