Up-to-date ACL authorizer

fd4s · Mar 28, 2022 · b29a524 · b29a524
1 parent c703388
commit b29a524
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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")