Page History

...

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

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

PingResponse

...

Format below:

Code Block
{ Version => int16 CorrelationId => int64 ErrorCode => int16 }

Consumer Failure Handling

...

MetadataRequest

{
  Version                => int16
  CorrelationId          => int64
  ClientId               => String
  Topics                 => [String]
  GroupIds               => [String]
}

MetadataResponse

{
  Version                => int16
  CorrelationId          => int64
  Brokers                => [Broker]
  TopicsMetadata         => [TopicMetadata]
  CoordinatorIds         => [int16]
}

...

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

JoinGroupRequest

...

theme

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

 

JoinGroupResponse

...

actionscript3

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

...