Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-15819

KafkaServer leaks KafkaRaftManager when ZK migration enabled

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 3.6.0
    • 3.7.0
    • kraft
    • None

    Description

      In SharedServer, TestRaftServer, and MetadataShell, the KafkaRaftManager is maintained as an instance variable, and shutdown when the outer instance is shutdown. However, in the KafkaServer, the KafkaRaftManager is instantiated and started, but then the reference is lost.

      https://github.com/apache/kafka/blob/49d3122d425171b6a59a2b6f02d3fe63d3ac2397/core/src/main/scala/kafka/server/KafkaServer.scala#L416-L442

      Instead, the KafkaServer should behave like the other call-sites of KafkaRaftManager, and shutdown the KafkaRaftManager during shutdown.

      Attachments

        Issue Links

          Activity

            People

              gharris1727 Greg Harris
              gharris1727 Greg Harris
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: