X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationIT.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationIT.java;h=0d09a76b8eaba6fcb68ecb23d2b21c384e6fc5ae;hb=db4b181f863add3e78c01d110c1b4feabd8ecb89;hp=aad79b89e82b77393b813712fdefe850596f65b9;hpb=8a56919f493faa0acc6eb939b9c78312a1418efa;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
index aad79b8..0d09a76 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
@@ -29,6 +29,8 @@ import static org.awaitility.Awaitility.*;
 		properties = {
 				"spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
 				"juplo.wordcount.counter.bootstrap-server=${spring.embedded.kafka.brokers}",
+				"juplo.wordcount.counter.commit-interval=0",
+				"juplo.wordcount.counter.cacheMaxBytes=0",
 				"juplo.wordcount.counter.input-topic=" + TOPIC_IN,
 				"juplo.wordcount.counter.output-topic=" + TOPIC_OUT })
 @EmbeddedKafka(topics = { TOPIC_IN, TOPIC_OUT }, partitions = PARTITIONS)