From 0b95dc05338d16442fb34057fc0ffe2efc4b6228 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Fri, 8 Nov 2019 14:40:05 -0500 Subject: [PATCH] Trying to address a CI build failure Related to replication-offset-checkpoint.tmp in inventory count kafka streams sample --- .../inventory/count/KafkaStreamsInventoryCountTests.java | 3 ++- .../count/SpringBootKafkaStreamsInventoryCountTests.java | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) 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 })