diff --git a/scheduler/data-flow/build.gradle.kts b/scheduler/data-flow/build.gradle.kts
index 08c24cf99e..120cec0cf0 100644
--- a/scheduler/data-flow/build.gradle.kts
+++ b/scheduler/data-flow/build.gradle.kts
@@ -29,8 +29,8 @@ dependencies {
     implementation("io.klogging:slf4j-klogging:0.11.1")
 
     // Kafka
-    implementation("org.apache.kafka:kafka-streams:8.0.0-ccs")
-    testImplementation("org.apache.kafka:kafka-streams-test-utils:8.0.0-ccs")
+    implementation("org.apache.kafka:kafka-streams:8.0.1-ce")
+    testImplementation("org.apache.kafka:kafka-streams-test-utils:8.0.1-ce")
     // https://mvnrepository.com/artifact/io.confluent/kafka-streams-protobuf-serde
     implementation("io.confluent:kafka-streams-protobuf-serde:8.0.0")