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