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