KAFKA-14170: Fix NPE in the deleteTopics() code path of KRaft Controller (#12533) (#7192)
Fix a bug in ReplicationControlManager where we got a NullPointerException when removing a topic with no offline replicas, and there were other topics that did have offline replicas. Fix an issue in MetadataDelta#replay where we were replaying RemoveTopicRecord twice. Reviewers: Colin P. McCabe <cmccabe@apache.org>, dengziming <dengziming1993@gmail.com>
显示
- core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala 1 个添加, 1 个删除...scala/unit/kafka/integration/KafkaServerTestHarness.scala
- core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala 36 个添加, 0 个删除...est/scala/unit/kafka/server/DeleteTopicsRequestTest.scala
- metadata/src/main/java/org/apache/kafka/controller/BrokersToIsrs.java 1 个添加, 1 个删除.../main/java/org/apache/kafka/controller/BrokersToIsrs.java
加载中
想要评论请 注册 或 登录