This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a0291a8d50d MINOR: Fix flaky state updater test (#18253)
add 4a6c6d1a1ea KAFKA-18284: Add group coordinator records for Streams
rebalance protocol (#18228)
No new revisions were added by this update.
Summary of changes:
...=> StreamsGroupCurrentMemberAssignmentKey.json} | 13 ++--
... StreamsGroupCurrentMemberAssignmentValue.json} | 29 ++++++---
...Key.json => StreamsGroupMemberMetadataKey.json} | 13 ++--
.../message/StreamsGroupMemberMetadataValue.json | 58 +++++++++++++++++
...gnmentKey.json => StreamsGroupMetadataKey.json} | 11 ++--
...taValue.json => StreamsGroupMetadataValue.json} | 3 +-
....json => StreamsGroupPartitionMetadataKey.json} | 11 ++--
...son => StreamsGroupPartitionMetadataValue.json} | 7 +-
... => StreamsGroupTargetAssignmentMemberKey.json} | 13 ++--
.../StreamsGroupTargetAssignmentMemberValue.json | 38 +++++++++++
...> StreamsGroupTargetAssignmentMetadataKey.json} | 11 ++--
...StreamsGroupTargetAssignmentMetadataValue.json} | 3 +-
...gnmentKey.json => StreamsGroupTopologyKey.json} | 11 ++--
.../common/message/StreamsGroupTopologyValue.json | 74 ++++++++++++++++++++++
14 files changed, 238 insertions(+), 57 deletions(-)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupMemberMetadataKey.json
=> StreamsGroupCurrentMemberAssignmentKey.json} (69%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupCurrentMemberAssignmentValue.json
=> StreamsGroupCurrentMemberAssignmentValue.json} (50%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupMemberMetadataKey.json
=> StreamsGroupMemberMetadataKey.json} (69%)
create mode 100644
group-coordinator/src/main/resources/common/message/StreamsGroupMemberMetadataValue.json
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupCurrentMemberAssignmentKey.json
=> StreamsGroupMetadataKey.json} (76%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupMetadataValue.json
=> StreamsGroupMetadataValue.json} (86%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupCurrentMemberAssignmentKey.json
=> StreamsGroupPartitionMetadataKey.json} (75%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupPartitionMetadataValue.json
=> StreamsGroupPartitionMetadataValue.json} (82%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupMemberMetadataKey.json
=> StreamsGroupTargetAssignmentMemberKey.json} (69%)
create mode 100644
group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMemberValue.json
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupCurrentMemberAssignmentKey.json
=> StreamsGroupTargetAssignmentMetadataKey.json} (75%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupTargetAssignmentMetadataValue.json
=> StreamsGroupTargetAssignmentMetadataValue.json} (85%)
copy
group-coordinator/src/main/resources/common/message/{ConsumerGroupCurrentMemberAssignmentKey.json
=> StreamsGroupTopologyKey.json} (76%)
create mode 100644
group-coordinator/src/main/resources/common/message/StreamsGroupTopologyValue.json
