Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
{
  Version                => int16
  CorrelationId          => int64int32
  ClientId               => String
  GroupId                => String
}

...

Code Block
{
  CorrelationId          => int64int32
  ErrorCode              => int16
  CoordinatorId          => Broker
  CoordinatorEpoch  GenerationId     => int32
  GroupGenerationId      => int64int32
}

JoinGroupRequest

 

Code Block
{
  Version                => int16
  CorrelationId          => int64int32
  GroupId                => String
  ConsumerHost           => String
  SessionTimeout         => int64int32
  Topics                 => [String]
}

JoinGroupResponse

Code Block
{
  Version                => int16
  CorrelationId          => int64int32
  ErrorCode              => int16
  GenerationIdGroupGenerationId           => int16int32
  GroupId                => String 
  ConsumerId             => String
  PartitionsToOwn        => [TopicAndPartition]
}

 

HeartbeatRequest

Code Block
{
  Version                => int16
  CorrelationId          => int64int32
  GroupId                => String
  ConsumerId             => String
}

...

Code Block
{
  CorrelationId          => int64int32
  GroupId                => String
  ConsumerId             => String
  ErrorCode              => int16
}

...