diff --git a/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala b/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala index 054ebea83396..8c9bc4f17748 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 e38cafd0efc3..74b1b757ecef 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