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

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


    from fa0324485b KAFKA-13654: Extend KStream process with new Processor API 
(#11993)
     add 9c3f605fc7 KAFKA-13835: Fix two bugs related to dynamic broker configs 
in KRaft (#12063)

No new revisions were added by this update.

Summary of changes:
 .../src/main/scala/kafka/server/BrokerServer.scala |  4 +-
 .../scala/kafka/server/DynamicBrokerConfig.scala   | 64 +++++++++++++++------
 .../server/metadata/BrokerMetadataListener.scala   | 18 ++++++
 .../server/metadata/BrokerMetadataPublisher.scala  | 41 ++++++++-----
 .../metadata/BrokerMetadataPublisherTest.scala     | 67 ++++++++++++++++++++++
 5 files changed, 162 insertions(+), 32 deletions(-)

Reply via email to