diff --git a/gradle.properties b/gradle.properties index c5b15127..a937933c 100644 --- a/gradle.properties +++ b/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 diff --git a/streams-bootstrap/build.gradle.kts b/streams-bootstrap/build.gradle.kts index 72a46cba..fb4613e6 100644 --- a/streams-bootstrap/build.gradle.kts +++ b/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") } diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpRunner.java b/streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpRunner.java index 1a6b0451..49893251 100644 --- a/streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpRunner.java +++ b/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 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) {