From 3f3337d09f48f450820d9942618bfcaf64a668b6 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Fri, 8 Nov 2019 14:59:15 -0500 Subject: [PATCH] Removing the watermark property added earlier --- .../inventory/count/KafkaStreamsInventoryCountTests.java | 3 +-- .../count/SpringBootKafkaStreamsInventoryCountTests.java | 1 - 2 files changed, 1 insertion(+), 3 deletions(-) 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 9112578..d281e2b 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 @@ -43,8 +43,7 @@ import org.springframework.test.annotation.DirtiesContext; * * @author David Turanski */ -@EmbeddedKafka(topics = KafkaStreamsInventoryCountTests.INPUT_TOPIC, - brokerProperties = {"replica.high.watermark.checkpoint.interval.ms=100000000"}) +@EmbeddedKafka(topics = KafkaStreamsInventoryCountTests.INPUT_TOPIC) @DirtiesContext public class KafkaStreamsInventoryCountTests extends AbstractInventoryCountTests{ 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 3f5514e..fd4475c 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 @@ -47,7 +47,6 @@ import org.springframework.test.annotation.DirtiesContext; */ @EmbeddedKafka( bootstrapServersProperty = "spring.kafka.bootstrap-servers", - brokerProperties = {"replica.high.watermark.checkpoint.interval.ms=100000000"}, topics = { SpringBootKafkaStreamsInventoryCountTests.INPUT_TOPIC })