diff --git a/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/KafkaStreamsInventoryCountTests.java b/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/KafkaStreamsInventoryCountTests.java index d196485..377fa52 100644 --- a/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/KafkaStreamsInventoryCountTests.java +++ b/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/KafkaStreamsInventoryCountTests.java @@ -42,7 +42,8 @@ import org.springframework.kafka.test.utils.KafkaTestUtils; * * @author David Turanski */ -@EmbeddedKafka(topics = KafkaStreamsInventoryCountTests.INPUT_TOPIC) +@EmbeddedKafka(topics = KafkaStreamsInventoryCountTests.INPUT_TOPIC, + brokerProperties = {"replica.high.watermark.checkpoint.interval.ms=100000000"}) public class KafkaStreamsInventoryCountTests extends AbstractInventoryCountTests{ static final String INPUT_TOPIC = "inventory-update-events"; diff --git a/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/SpringBootKafkaStreamsInventoryCountTests.java b/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/SpringBootKafkaStreamsInventoryCountTests.java index 4d6718e..733b0f1 100644 --- a/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/SpringBootKafkaStreamsInventoryCountTests.java +++ b/kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/SpringBootKafkaStreamsInventoryCountTests.java @@ -46,6 +46,7 @@ import org.springframework.kafka.test.utils.KafkaTestUtils; */ @EmbeddedKafka( bootstrapServersProperty = "spring.kafka.bootstrap-servers", + brokerProperties = {"replica.high.watermark.checkpoint.interval.ms=100000000"}, topics = { SpringBootKafkaStreamsInventoryCountTests.INPUT_TOPIC })