You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by di...@apache.org on 2023/12/28 10:12:37 UTC

(kafka) branch 3.6 updated: KAFKA-16053: Fix memory leaks due to KDC server in tests (#15079)

This is an automated email from the ASF dual-hosted git repository.

divijv pushed a commit to branch 3.6
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.6 by this push:
     new eea778d5c57 KAFKA-16053: Fix memory leaks due to KDC server in tests (#15079)
eea778d5c57 is described below

commit eea778d5c5782f5c02fa2afdbc1801182c70790e
Author: Divij Vaidya <di...@amazon.com>
AuthorDate: Thu Dec 28 10:55:14 2023 +0100

    KAFKA-16053: Fix memory leaks due to KDC server in tests (#15079)
    
    This commit closes the KDC server properly in `CustomQuotaCallbackTest` and `AclAuthorizerWithZkSaslTest`.
    
    Reviewers: Justine Olshan <jo...@confluent.io>
---
 core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala  | 1 +
 .../unit/kafka/security/authorizer/AclAuthorizerWithZkSaslTest.scala     | 1 +
 2 files changed, 2 insertions(+)

diff --git a/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala b/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala
index 054ebea8339..8c9bc4f1774 100644
--- a/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala
+++ b/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala
@@ -78,6 +78,7 @@ class CustomQuotaCallbackTest extends IntegrationTestHarness with SaslSetup {
     adminClients.foreach(_.close())
     GroupedUserQuotaCallback.tearDown()
     super.tearDown()
+    closeSasl()
   }
 
   override def configureSecurityBeforeServersStart(testInfo: TestInfo): Unit = {
diff --git a/core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerWithZkSaslTest.scala b/core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerWithZkSaslTest.scala
index e38cafd0efc..74b1b757ece 100644
--- a/core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerWithZkSaslTest.scala
+++ b/core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerWithZkSaslTest.scala
@@ -91,6 +91,7 @@ class AclAuthorizerWithZkSaslTest extends QuorumTestHarness with SaslSetup {
     aclAuthorizer.close()
     aclAuthorizer2.close()
     super.tearDown()
+    closeSasl()
   }
 
   @Test