THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- On startup or on co-ordinator failover, the consumer sends a ClusterMetadataRequest ConsumerMetadataRequest to any of the brokers in the "bootstrap.brokers" list. In the ClusterMetadataResponseConsumerMetadataResponse, it receives the location of the co-ordinator for it's group.
- The consumer sends a RegisterConsumer request to it's co-ordinator broker. In the RegisterConsumerResponse, it receives the list of topic partitions that it should own.
- At this time, group management is done and the consumer starts fetching data and (optionally) committing offsets for the list of partitions it owns.
...
Code Block |
---|
{ Version => int16 CorrelationId => int64 GroupId => String ConsumerHost => String SessionTimeout => int64 Topics => [String] } |
JoinGroupResponse
Code Block |
---|
{ Version => int16 CorrelationId => int64 ErrorCode => int16 GenerationId => int16 GroupId => String ConsumerId => String PartitionsToOwn => [TopicAndPartition] } |
HeartbeatRequest
Code Block |
---|
{ Version => int16 CorrelationId => int64 GroupId => String ConsumerId => String } |
...