This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch kip1071_trunk_rebase_11_25_add_Bruno_PR
in repository https://gitbox.apache.org/repos/asf/kafka.git
from db0c2da5df7 Changes from rebase
add b1b9e73759a Fix rebase
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractMembershipManager.java | 2 +-
.../consumer/internals/AsyncKafkaConsumer.java | 6 +--
.../consumer/internals/CommitRequestManager.java | 2 +-
.../consumer/internals/MemberStateListener.java | 2 +-
.../consumer/internals/RequestManagers.java | 60 +++++++++++++---------
.../internals/StreamsMembershipManager.java | 23 ++-------
.../events/ApplicationEventProcessor.java | 53 +++++++++++++++++--
.../internals/StreamsMembershipManagerTest.java | 1 -
.../events/ApplicationEventProcessorTest.java | 4 +-
.../coordinator/group/GroupCoordinatorShard.java | 21 +++++---
.../streams/CoordinatorStreamsRecordHelpers.java | 28 +++++-----
.../message/ConsumerGroupRegularExpressionKey.json | 4 +-
.../StreamsGroupCurrentMemberAssignmentKey.json | 6 +--
.../message/StreamsGroupMemberMetadataKey.json | 6 +--
.../common/message/StreamsGroupMetadataKey.json | 4 +-
.../message/StreamsGroupPartitionMetadataKey.json | 4 +-
.../StreamsGroupTargetAssignmentMemberKey.json | 6 +--
.../StreamsGroupTargetAssignmentMetadataKey.json | 4 +-
.../common/message/StreamsGroupTopologyKey.json | 4 +-
.../CoordinatorStreamsRecordHelpersTest.java | 2 +-
20 files changed, 147 insertions(+), 95 deletions(-)
