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

Posted to commits@kafka.apache.org by bo...@apache.org on 2020/11/12 07:22:50 UTC

[kafka] branch trunk updated (1565849 -> bb34c5c)

This is an automated email from the ASF dual-hosted git repository.

boyang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 1565849  MINOR: Remove the extra brackets in the demo code (#9586)
     add bb34c5c  KAFKA-10350: add forwarding manager implementation with metrics (#9580)

No new revisions were added by this update.

Summary of changes:
 .../main/scala/kafka/network/RequestChannel.scala  |  1 +
 .../BrokerToControllerChannelManagerImpl.scala     | 48 +-----------
 .../scala/kafka/server/ForwardingManager.scala     | 85 ++++++++++++++++++++++
 core/src/main/scala/kafka/server/KafkaApis.scala   |  2 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |  4 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  2 +-
 .../jmh/metadata/MetadataRequestBenchmark.java     |  6 +-
 7 files changed, 95 insertions(+), 53 deletions(-)
 create mode 100644 core/src/main/scala/kafka/server/ForwardingManager.scala