This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from e9c50b1f4b0 KAFKA-16369: Broker may not shut down when SocketServer
fails to bind as Address already in use (#15530)
add 5c929874b88 KAFKA-16312, KAFKA-16185: Local epochs in reconciliation
(#15511)
No new revisions were added by this update.
Summary of changes:
.../internals/HeartbeatRequestManager.java | 33 ++-
.../consumer/internals/MembershipManager.java | 91 ++++++-
.../consumer/internals/MembershipManagerImpl.java | 122 +++++----
.../internals/HeartbeatRequestManagerTest.java | 149 +++++++----
.../internals/MembershipManagerImplTest.java | 280 ++++++++++++++++-----
5 files changed, 485 insertions(+), 190 deletions(-)
