THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
JoinGroupRequest => GroupId SessionTimeout RebalanceTimeout MemberId GroupInstanceId ProtocolType GroupProtocols GroupId => String SessionTimeout => int32 RebalanceTimeout => int32 MemberId => String GroupInstanceId => String // new ProtocolType => String GroupProtocols => [Protocol MemberMetadata] Protocol => String MemberMetadata => bytes JoinGroupResponse => ThrottleTime ErrorCode GenerationId ProtocolName LeaderId MemberId Members ThrottleTime => int16 ErrorCode => int16 GenerationId => int32 ProtocolName => String LeaderId => String MemberId => String Members => []JoinGroupResponseMember MemberId => String GroupInstanceId => String // new Metadata => bytes SyncGroupRequest => GroupId GenerationId MemberId GroupInstanceId Assignments GroupId => String GenerationId => int32 MemberId => String GroupInstanceId => String // new Assignments => []SyncGroupRequestAssignment MemberId => String GroupInstanceId => String // new Assignment => bytes SyncGroupResponse => ThrottleTime ErrorCode Assignment ThrottleTime => int16 ErrorCode => int16 Assignment => bytes HeartbeatRequest => GroupId GenerationId MemberId GroupInstanceId GroupId => String GenerationId => int32 MemberId => String GroupInstanceId => String // new HeartbeatResponse => ThrottleTime ErrorCode Assignment ThrottleTime => int16 ErrorCode => int16 OffsetCommitRequest => GroupId GenerationId MemberId GroupInstanceId Topics GroupId => String GenerationId => int32 MemberId => String GroupInstanceId => String // new Topics => []OffsetCommitRequestTopic Name => String Partitions => []OffsetCommitRequestPartition PartitionIndex => int32 CommittedOffset => int64 CommittedLeaderEpoch => int32 CommitTimestamp => int64 CommittedMetadata => String OffsetCommitResponse => ThrottleTime Topics ThrottleTime => int16 Topics => []OffsetCommitResponseTopic Name => String Partitions => []OffsetCommitResponsePartition PartitionIndex => int32 ErrorCode => int16 LeaveGroupRequest => GroupId MemberIdentityList GroupId => String MemberId => String // removed MemberIdentityList => List[Tuple[String, String]]]MemberIdentity // new MemberId => String GroupInstanceId => String |
In the meantime, we bump the join/leave group request/response version to v4/v3.
...