Update

bakdata · Jun 25, 2024 · 3cf0503 · 3cf0503
1 parent 9addc66
commit 3cf0503
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/RunningStreams.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/RunningStreams.java
@@ -44,7 +44,7 @@
 public class RunningStreams {
 
     @NonNull
-    StreamsConfig config;
+    ImprovedStreamsConfig config;
     @NonNull
     Topology topology;
     @NonNull

diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java
@@ -38,7 +38,7 @@
 @Slf4j
 public final class StreamsRunner implements Runner {
 
-    private final @NonNull StreamsConfig config;
+    private final @NonNull ImprovedStreamsConfig config;
     private final @NonNull Topology topology;
     private final @NonNull KafkaStreams streams;
     private final @NonNull CapturingStreamsUncaughtExceptionHandler exceptionHandler;
@@ -63,7 +63,7 @@ public StreamsRunner(final @NonNull Topology topology, final @NonNull StreamsCon
      */
     public StreamsRunner(final @NonNull Topology topology, final @NonNull StreamsConfig config,
             final @NonNull StreamsExecutionOptions options) {
-        this.config = config;
+        this.config = new ImprovedStreamsConfig(config);
         this.topology = topology;
         this.streams = new KafkaStreams(topology, config);
         this.exceptionHandler = new CapturingStreamsUncaughtExceptionHandler(options.createUncaughtExceptionHandler());