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

Fix tests

Browse Source
This commit is contained in:
Soby Chacko
2020-10-22 10:42:33 -04:00
parent 5ff96b4174
commit 1b6d42d883
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka-streams-samples/kafka-streams-word-count/src/main/java/kafka/streams/word/count/KafkaStreamsWordCountApplication.java
View File

@@ -44,7 +44,7 @@ public class KafkaStreamsWordCountApplication {
public static final String INPUT_TOPIC = "input";
public static final String OUTPUT_TOPIC = "output";
public static final int WINDOW_SIZE_MS = 1000;
public static final int WINDOW_SIZE_MS = 30_000;
@Bean
public Function<KStream<Bytes, String>, KStream<Bytes, WordCount>> process() {

4
kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml
View File

@@ -2,8 +2,8 @@ spring.cloud.stream:
function:
definition: process
bindings:
process-in-0: input
process-out-0: output
process-in-0: words
process-out-0: counts
# bindings:
# input:
# destination: input

2
kafka-streams-samples/kafka-streams-word-count/src/test/java/kafka/streams/word/count/WordCountProcessorApplicationTests.java
View File

@@ -78,7 +78,7 @@ public class WordCountProcessorApplicationTests {
KafkaStreamsWordCountApplication.WordCountProcessorApplication app = new KafkaStreamsWordCountApplication.WordCountProcessorApplication();
//final Function<KStream<Bytes, String>, KStream<Bytes, KafkaStreamsWordCountApplication.WordCount>> process = app.process();
final Function<KStream<Bytes, String>, KStream<Bytes, KafkaStreamsWordCountApplication.WordCount>> process = null;
final Function<KStream<Bytes, String>, KStream<Bytes, KafkaStreamsWordCountApplication.WordCount>> process = app.process();
final KStream<Bytes, KafkaStreamsWordCountApplication.WordCount> output = process.apply(input);