Kafka 3.1.0, Confluent 7.1.0 + minor bumps (#24)

* Kafka 3.1.0 & minor dep bumps

* Missade en bit i readmen.

* Confluent bump to 7.0.1, replaced deprecated simpleaclauthorizer

* Readme update

* Confluent 7.1 & fler dep bumps

* Readme fiks

README.md

@@ -5,7 +5,7 @@
 
 A simple API for creating an embedded Kafka environment with the KafkaEnvironment class, typically used for running integration tests. 
 
-Based on the [Confluent Open Source distribution](https://www.confluent.io/product/confluent-open-source/) v6.2.1. 
+Based on the [Confluent Open Source distribution](https://www.confluent.io/product/confluent-open-source/) v7.1.x.
 
 Instead of using the classic ports (2181, 9092, ...) for each server, the class will get the required number of available ports 
 and use those in configurations for each server. 
@@ -51,7 +51,7 @@ Add the dependency:
 #### Gradle
 ```
 dependencies {
-    testImplementation "no.nav:kafka-embedded-env:2.8.1"
+    testImplementation "no.nav:kafka-embedded-env:3.1.0"
 }
 ```
 
@@ -60,13 +60,12 @@ dependencies {
 <dependency>
     <groupId>no.nav</groupId>
     <artifactId>kafka-embedded-env</artifactId>
-    <version>2.8.1</version>
+    <version>3.1.0</version>
     <scope>test</scope>
 </dependency>
 ```
 
-**Note**: It is recommended that you use the Confluent version matching this library - currently v6.x
-(i.e. Kafka v2.x, though it is likely that Confluent v4.x/Kafka v1.x will also work)
+**Note**: It is recommended that you use the Confluent version matching this library - currently v7.1.x
 
 ## Examples
 ### Default
@@ -172,6 +171,14 @@ for the set of available operations.
 
 ## Changelog
 
+### [3.1.0]
+- Kafka 3.1.0
+- Confluent Platform 7.1.0
+- Kotlin 1.6.20
+- Ktor 1.6.8
+- Logback 1.2.11
+- Slf4j 1.7.33
+
 ### [2.8.1]
 - Multiple dependency bumps:
 - Kafka 2.8.1

pom.xml

@@ -4,20 +4,20 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>no.nav</groupId>
     <artifactId>kafka-embedded-env</artifactId>
-    <version>2.8.1-SNAPSHOT</version>
+    <version>3.1.0-SNAPSHOT</version>
     <name>kafka-embedded-env</name>
     <description>Simple API for running a Kafka/Confluent environment locally</description>
     <url>https://github.com/navikt/kafka-embedded-env</url>
 
     <properties>
-        <kotlin.version>1.6.0</kotlin.version>
-        <kafka.version>2.8.1</kafka.version>
-        <ktor.version>1.6.5</ktor.version>
-        <confluent.version>6.2.1</confluent.version>
+        <kotlin.version>1.6.20</kotlin.version>
+        <kafka.version>3.1.0</kafka.version>
+        <ktor.version>1.6.8</ktor.version>
+        <confluent.version>7.1.0</confluent.version>
         <spek.version>2.0.17</spek.version>
         <kluent.version>1.68</kluent.version>
-        <logback.version>1.2.7</logback.version>
-        <slf4j.version>1.7.32</slf4j.version>
+        <logback.version>1.2.11</logback.version>
+        <slf4j.version>1.7.33</slf4j.version>
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/kotlin/no/nav/common/embeddedkafka/KBServer.kt

@@ -74,7 +74,7 @@ class KBServer(
             set("security.inter.broker.protocol", "SASL_PLAINTEXT")
             set("sasl.mechanism.inter.broker.protocol", "PLAIN")
             set("sasl.enabled.mechanisms", "PLAIN")
-            set("authorizer.class.name", "kafka.security.auth.SimpleAclAuthorizer")
+            set("authorizer.class.name", "kafka.security.authorizer.AclAuthorizer")
             set("super.users", "User:${kafkaAdmin.username};User:${kafkaClient.username}")
             // allow.everyone.if.no.acl.found=true
             // auto.create.topics.enable=false