This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 69eebbf KAFKA-12440; ClusterId validation for Vote, BeginQuorum,
EndQuorum and FetchSnapshot (#10289)
add ca166ea KAFKA-9189: Use MetadataCache instead of ZK during controlled
shutdown to avoid hang (#10361)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/server/KafkaServer.scala | 18 +++++------
.../kafka/server/metadata/MetadataBrokers.scala | 5 ++++
.../unit/kafka/server/ServerShutdownTest.scala | 35 +++++++++++-----------
.../scala/unit/kafka/zk/ZooKeeperTestHarness.scala | 8 +++--
4 files changed, 35 insertions(+), 31 deletions(-)
