Upgrade to Kafka 3.6

gradle.properties

@@ -1,7 +1,7 @@
 version=2.16.2-SNAPSHOT
 org.gradle.caching=true
 org.gradle.parallel=true
-kafkaVersion=3.5.2
-confluentVersion=7.5.1
-fluentKafkaVersion=2.11.3
+kafkaVersion=3.6.1
+confluentVersion=7.6.0
+fluentKafkaVersion=2.12.0
 org.gradle.jvmargs=-Xmx2048m

streams-bootstrap/build.gradle.kts

@@ -14,7 +14,7 @@ dependencies {
     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.22.1"
+    val log4jVersion = "2.23.0"
     implementation(group = "org.apache.logging.log4j", name = "log4j-core", version = log4jVersion)
     implementation(group = "org.apache.logging.log4j", name = "log4j-slf4j2-impl", version = log4jVersion)
     api(
@@ -25,13 +25,13 @@ dependencies {
     implementation(group = "com.google.guava", name = "guava", version = "33.0.0-jre")
     implementation(group = "org.jooq", name = "jool", version = "0.9.14")
 
-    val junitVersion = "5.10.1"
+    val junitVersion = "5.10.2"
     testImplementation(group = "org.junit.jupiter", name = "junit-jupiter-api", version = junitVersion)
     testImplementation(group = "org.junit.jupiter", name = "junit-jupiter-params", version = junitVersion)
     testImplementation(group = "org.junit-pioneer", name = "junit-pioneer", version = "2.2.0")
     testRuntimeOnly(group = "org.junit.jupiter", name = "junit-jupiter-engine", version = junitVersion)
-    testImplementation(group = "org.assertj", name = "assertj-core", version = "3.25.1")
-    val mockitoVersion = "5.8.0"
+    testImplementation(group = "org.assertj", name = "assertj-core", version = "3.25.3")
+    val mockitoVersion = "5.10.0"
     testImplementation(group = "org.mockito", name = "mockito-core", version = mockitoVersion)
     testImplementation(group = "org.mockito", name = "mockito-junit-jupiter", version = mockitoVersion)
 
@@ -43,7 +43,7 @@ dependencies {
         name = "schema-registry-mock-junit5",
         version = fluentKafkaVersion
     )
-    testImplementation(group = "net.mguenther.kafka", name = "kafka-junit", version = "3.5.0") {
+    testImplementation(group = "net.mguenther.kafka", name = "kafka-junit", version = "3.6.0") {
         exclude(group = "org.slf4j", module = "slf4j-log4j12")
     }
 

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

@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2023 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal
@@ -101,7 +101,7 @@ public static void runResetter(final Collection<String> inputTopics, final Colle
         }
         final String[] args = argList.build().toArray(String[]::new);
         final StreamsResetter resetter = new StreamsResetter();
-        final int returnCode = resetter.run(args);
+        final int returnCode = resetter.execute(args);
         try {
             Files.delete(tempFile.toPath());
         } catch (final IOException e) {