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

Add Junit5 test extension which detects leaked Kafka clients and servers

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: In Progress
    • Major
    • Resolution: Unresolved
    • None
    • None
    • clients
    • None

    Description

      We have many tests which accidentally leak Kafka clients and servers. This contributes to test flakiness and build instability.

      We should use a test extension to make it easier to find these leaked clients and servers, and force test-implementors to resolve their resource leaks prior to merge.

      Attachments

        Issue Links

        relates to

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-15343 Fix MirrorConnectIntegrationTests causing ci build failures.

        • Major - Major loss of function.
        • In Progress

        Improvement - An improvement or enhancement to an existing feature or task. KAFKA-16072 Create Junit 5 extension to detect thread leak

        • Major - Major loss of function.
        • Open
        Testing discovered

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-16768 SocketServer leaks accepted SocketChannel instances due to race condition

        • Major - Major loss of function.
        • Open

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-15826 WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Open

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-15834 Subscribing to non-existent topic blocks StreamThread from stopping

        • Major - Major loss of function.
        • Resolved

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-15804 Broker leaks ServerSocketChannel when exception is thrown from ZkConfigManager during startup

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-15816 Typos in tests leak network sockets

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-15819 KafkaServer leaks KafkaRaftManager when ZK migration enabled

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-15827 KafkaBasedLog.withExistingClients leaks clients if start is not called

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-16765 NioEchoServer leaks accepted SocketChannel instances due to race condition

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-16967 NioEchoServer fails to register connection and causes flaky failure

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-17201 SelectorTest.testInboundConnectionsCountInConnectionCreationMetric leaks sockets and threads

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Test - A new unit, integration or system test. KAFKA-17207 ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), leaking clients

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Open

        Test - A new unit, integration or system test. KAFKA-16702 KafkaLog4jAppenderTest leaks producer instances

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Test - A new unit, integration or system test. KAFKA-17202 EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpointedOffset leaks consumers

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Test - A new unit, integration or system test. KAFKA-17203 StreamThread leaking producer instances

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved

        Test - A new unit, integration or system test. KAFKA-17204 KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Resolved
        links to

        Web Link GitHub Pull Request #14783

        Activity
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

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

            Dates

              Created:
              Updated:

              Slack

                Issue deployment