Upgrade to Kafka 3.5 (#192)

gradle.properties

@@ -1,7 +1,7 @@
 version=2.14.1-SNAPSHOT
 org.gradle.caching=true
 org.gradle.parallel=true
-kafkaVersion=3.4.0
-confluentVersion=7.4.0
-fluentKafkaVersion=2.10.0
+kafkaVersion=3.5.1
+confluentVersion=7.5.1
+fluentKafkaVersion=2.11.0
 org.gradle.jvmargs=-Xmx2048m

streams-bootstrap/build.gradle.kts

@@ -6,17 +6,17 @@ plugins {
 
 dependencies {
     val kafkaVersion: String by project
-    implementation(group = "org.apache.kafka", name = "kafka_2.13", version = kafkaVersion)
+    implementation(group = "org.apache.kafka", name = "kafka-tools", version = kafkaVersion)
 
     implementation(group = "info.picocli", name = "picocli", version = "4.7.0")
     api(group = "org.apache.kafka", name = "kafka-streams", version = kafkaVersion)
     api(group = "org.apache.kafka", name = "kafka-clients", version = kafkaVersion)
     val confluentVersion: String by project
     implementation(group = "io.confluent", name = "kafka-streams-avro-serde", version = confluentVersion)
     api(group = "io.confluent", name = "kafka-schema-registry-client", version = confluentVersion)
-    val log4jVersion = "2.19.0"
+    val log4jVersion = "2.21.1"
     implementation(group = "org.apache.logging.log4j", name = "log4j-core", version = log4jVersion)
-    implementation(group = "org.apache.logging.log4j", name = "log4j-slf4j-impl", version = log4jVersion)
+    implementation(group = "org.apache.logging.log4j", name = "log4j-slf4j2-impl", version = log4jVersion)
     implementation(group = "com.google.guava", name = "guava", version = "31.1-jre")
     implementation(group = "org.jooq", name = "jool", version = "0.9.14")
 
@@ -38,7 +38,7 @@ dependencies {
         name = "schema-registry-mock-junit5",
         version = fluentKafkaVersion
     )
-    testImplementation(group = "net.mguenther.kafka", name = "kafka-junit", version = "3.4.0") {
+    testImplementation(group = "net.mguenther.kafka", name = "kafka-junit", version = "3.5.0") {
         exclude(group = "org.slf4j", module = "slf4j-log4j12")
     }
 

streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpRunner.java

@@ -41,13 +41,13 @@
 import java.util.Properties;
 import java.util.function.Consumer;
 import java.util.stream.Collectors;
-import kafka.tools.StreamsResetter;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.streams.KafkaStreams;
 import org.apache.kafka.streams.Topology;
+import org.apache.kafka.tools.StreamsResetter;
 
 
 /**