THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
------------------------------------------------------------------------------------------------
PingRequest
Code Block | ||||
---|---|---|---|---|
| ||||
{ Version => int16 CorrelationId => int64 GroupId => String ConsumerId => String } |
...
---------------------------------------------------------------------------------------
MetadataRequest
...
Code Block | ||||
---|---|---|---|---|
| ||||
{ Version => int16 CorrelationId => int64 ClientId => String Topics => [String] GroupIds => [String] } |
This MetadataRequest inherits from the TopicMetadataRequest in 0.8.
...
---------------------------------------------------------------------------------------
JoinGroupRequest
...
Code Block | ||||
---|---|---|---|---|
| ||||
{ Version => int16 CorrelationId => int64 GroupId => String ConsumerAddr => String SessionTimeout => int64 Subscribing => [String] } |
JoinGroupResponse
...
Code Block | ||||
---|---|---|---|---|
| ||||
{ Version => int16 CorrelationId => int64 ErrorCode => int16 Generation => int16 GroupId => String ConsumerId => String PartitionsToOwn => [<TopicAndPartition>] } |
Note that the consumer id is assigned by the coordinator upon joining the group, which is then used in heartbeat protocol and offset management.
...