SpringCloud/spring-cloud-stream-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Trying to address a CI build failure

Browse Source 
Related to replication-offset-checkpoint.tmp in inventory count kafka streams sample
This commit is contained in:
Soby Chacko
2019-11-08 14:40:05 -05:00
parent 295a2cfb71
commit 0b95dc0533
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/KafkaStreamsInventoryCountTests.java
View File

@@ -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";

1
kafka-streams-samples/kafka-streams-inventory-count/src/test/java/kafka/streams/inventory/count/SpringBootKafkaStreamsInventoryCountTests.java
View File

@@ -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
})