This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 802ee10 KAFKA-10348: Share client channel between forwarding and auto
creation manager (#10135)
add 2387d19 KAFKA-12352: Make sure all rejoin group and reset state has a
reason (#10232)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/consumer/KafkaConsumer.java | 2 +-
.../consumer/internals/AbstractCoordinator.java | 51 ++++++++++------------
.../consumer/internals/ConsumerCoordinator.java | 28 ++++++------
.../internals/AbstractCoordinatorTest.java | 2 +-
.../runtime/distributed/WorkerCoordinator.java | 3 +-
.../runtime/distributed/WorkerGroupMember.java | 2 +-
.../runtime/distributed/WorkerCoordinatorTest.java | 2 +-
7 files changed, 42 insertions(+), 48 deletions(-)
