This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from cf329cb MINOR: add missing space to errro message when setting uint16
(#10274)
add 31a121c KAFKA-12403; Ensure local state deleted on
`RemoveTopicRecord` received (#10252)
No new revisions were added by this update.
Summary of changes:
.../src/main/scala/kafka/server/BrokerServer.scala | 1 -
.../server/metadata/BrokerMetadataListener.scala | 55 +++---
.../server/metadata/CachedConfigRepository.scala | 11 +-
.../kafka/server/metadata/MetadataPartitions.scala | 95 ++++++++---
.../server/metadata/MetadataPartitionsTest.scala | 158 +++++++++++++++--
.../metadata/BrokerMetadataListenerTest.scala | 187 +++++++++++++++++++++
.../apache/kafka/controller/QuorumController.java | 2 +-
.../controller/ReplicationControlManager.java | 10 +-
.../controller/ReplicationControlManagerTest.java | 1 -
9 files changed, 441 insertions(+), 79 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataListenerTest.scala
