From b29a524f271349a4d59b364b9c37c462e3d4c9b7 Mon Sep 17 00:00:00 2001
From: Ben Plommer <ben.plommer@gmail.com>
Date: Mon, 28 Mar 2022 11:41:40 +0100
Subject: [PATCH] Up-to-date ACL authorizer

---
 modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala | 1 +
 1 file changed, 1 insertion(+)

diff --git a/modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala b/modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala
index 2690eb8ef..1cd47ae8b 100644
--- a/modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala
@@ -83,6 +83,7 @@ abstract class BaseKafkaSpec extends BaseAsyncSpec with ForEachTestContainer {
           transactionTimeoutInterval.toMillis.toString
         )
         .withEnv("KAFKA_TRANSACTION_STATE_LOG_MIN_ISR", "1")
+        .withEnv("KAFKA_AUTHORIZER_CLASS_NAME", "kafka.security.authorizer.AclAuthorizer")
         .withEnv("KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND", "true")
         .setDockerImageName(s"$imageName:$imageVersion")