Page History

...

------------------------------------------------------------------------------------------------

PingRequest

{
  Version                => int16
  CorrelationId          => int64
  GroupId                => String
  ConsumerId             => String
}

...

---------------------------------------------------------------------------------------

MetadataRequest

...

Code Block
theme Eclipse language actionscript3
{ Version => int16 CorrelationId => int64 ClientId => String Topics => [String] GroupIds => [String] }

 

This MetadataRequest inherits from the TopicMetadataRequest in 0.8.

...

---------------------------------------------------------------------------------------

JoinGroupRequest

...

Code Block
theme Eclipse language actionscript3
{ Version => int16 CorrelationId => int64 GroupId => String ConsumerAddr => String  SessionTimeout => int64 Subscribing => [String] }

 

JoinGroupResponse

...

Code Block
theme Eclipse language actionscript3
{ 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.

...