Create v3

bakdata · Apr 5, 2024 · bee1b33 · bee1b33
1 parent ee6e226
commit bee1b33
Show file tree

Hide file tree

Showing 2 changed files with 54 additions and 57 deletions.
diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/integration/RunStreamsAppTest.java b/streams-bootstrap/src/test/java/com/bakdata/kafka/integration/RunStreamsAppTest.java
@@ -58,6 +58,7 @@
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.apache.kafka.streams.KafkaStreams.State;
 import org.apache.kafka.streams.KafkaStreams.StateListener;
+import org.apache.kafka.streams.StreamsConfig;
 import org.apache.kafka.streams.errors.MissingSourceTopicException;
 import org.apache.kafka.streams.errors.StreamsException;
 import org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler;
@@ -96,6 +97,7 @@ static void run(final StreamsRunner runner) {
     static ConfiguredStreamsApp<StreamsApp> configureApp(final StreamsApp app, final StreamsTopicConfig topics) {
         final StreamsAppConfiguration configuration = StreamsAppConfiguration.builder()
                 .kafkaConfig(Map.of(
+                        StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, "0",
                         ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "10000"
                 ))
                 .topics(topics)