You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jg...@apache.org on 2021/03/08 19:23:31 UTC

[kafka] branch trunk updated (cf329cb -> 31a121c)

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