You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by gu...@apache.org on 2021/03/15 16:26:09 UTC

[kafka] branch trunk updated (802ee10 -> 2387d19)

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(-)