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 03edcdd KAFKA-13128: wait for all keys to be fully processed in
#shouldQueryStoresAfterAddingAndRemovingStreamThread (#11113)
add a75997f KAFKA-13127; Fix stray topic partition deletion for kraft
(#11118)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/log/Log.scala | 1 +
.../main/scala/kafka/server/ReplicaManager.scala | 8 +-
.../server/metadata/BrokerMetadataPublisher.scala | 50 +++++-----
.../kafka/server/KRaftClusterTest.scala | 5 +-
.../server/AbstractApiVersionsRequestTest.scala | 5 +-
.../kafka/server/ClientQuotasRequestTest.scala | 2 +
.../kafka/server/DescribeQuorumRequestTest.scala | 2 +
.../metadata/BrokerMetadataPublisherTest.scala | 105 ++++++++++++++++++++-
8 files changed, 148 insertions(+), 30 deletions(-)
