home/spring-cloud-stream-samples
2
0
Fork 0
mirror of https://github.com/wahyd4/spring-cloud-stream-samples.git synced 2026-08-09 05:16:18 +10:00
Code Issues Packages Projects Releases Wiki Activity

Removing the watermark property added earlier

Browse Source
This commit is contained in:
Soby Chacko
2019-11-08 14:59:15 -05:00
parent f29ce89a27
commit 3f3337d09f
2 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/KafkaStreamsInventoryCountTests.java
+1 -2
View File
@@ -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{
kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/SpringBootKafkaStreamsInventoryCountTests.java
-1
View File
@@ -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
})