This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from ea7da09e530 KAFKA-17899 Add more unit tests for NetworkReceive (#17637)
add 6f040cabc7c KAFKA-17116 New consumer may not send effective leave
group if member ID received after close (#17549)
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractMembershipManager.java | 91 +++++-------
.../consumer/internals/AsyncKafkaConsumer.java | 17 +--
.../consumer/internals/CommitRequestManager.java | 67 ++++-----
.../internals/ConsumerHeartbeatRequestManager.java | 2 +-
.../internals/ConsumerMembershipManager.java | 17 ---
.../consumer/internals/MemberStateListener.java | 8 +-
.../consumer/internals/RequestManagers.java | 22 ++-
.../internals/ShareConsumeRequestManager.java | 4 +-
.../internals/ShareHeartbeatRequestManager.java | 2 +-
.../consumer/internals/ShareMembershipManager.java | 18 ---
.../requests/ConsumerGroupHeartbeatRequest.java | 8 ++
.../message/ConsumerGroupHeartbeatRequest.json | 4 +-
.../message/ConsumerGroupHeartbeatResponse.json | 2 +-
.../common/message/DescribeGroupsResponse.json | 2 +-
.../common/message/OffsetFetchRequest.json | 2 +-
.../common/message/ShareGroupHeartbeatRequest.json | 2 +-
.../message/ShareGroupHeartbeatResponse.json | 2 +-
.../consumer/internals/AsyncKafkaConsumerTest.java | 4 +-
.../internals/CommitRequestManagerTest.java | 15 +-
.../ConsumerHeartbeatRequestManagerTest.java | 11 +-
.../internals/ConsumerMembershipManagerTest.java | 116 +++++++--------
.../internals/ShareConsumeRequestManagerTest.java | 2 +-
.../internals/ShareMembershipManagerTest.java | 100 ++++++-------
.../server/ConsumerGroupDescribeRequestTest.scala | 3 +-
.../server/ConsumerGroupHeartbeatRequestTest.scala | 158 +++++++++++++++------
.../server/ConsumerProtocolMigrationTest.scala | 14 +-
.../server/GroupCoordinatorBaseRequestTest.scala | 12 +-
.../server/ShareGroupHeartbeatRequestTest.scala | 18 ++-
.../coordinator/group/GroupMetadataManager.java | 30 ++--
.../group/GroupMetadataManagerTest.java | 107 +++++++++-----
.../group/GroupMetadataManagerTestContext.java | 9 +-
31 files changed, 487 insertions(+), 382 deletions(-)
