From 1b6d42d88361529e554128a6c04ba3f8fb1e7242 Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Thu, 22 Oct 2020 10:42:33 -0400
Subject: [PATCH] Fix tests

---
 .../streams/word/count/KafkaStreamsWordCountApplication.java  | 2 +-
 .../src/main/resources/application.yml                        | 4 ++--
 .../word/count/WordCountProcessorApplicationTests.java        | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/kafka-streams-samples/kafka-streams-word-count/src/main/java/kafka/streams/word/count/KafkaStreamsWordCountApplication.java b/kafka-streams-samples/kafka-streams-word-count/src/main/java/kafka/streams/word/count/KafkaStreamsWordCountApplication.java
index d8c4b1d..9d93ade 100644
--- a/kafka-streams-samples/kafka-streams-word-count/src/main/java/kafka/streams/word/count/KafkaStreamsWordCountApplication.java
+++ b/kafka-streams-samples/kafka-streams-word-count/src/main/java/kafka/streams/word/count/KafkaStreamsWordCountApplication.java
@@ -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() {
diff --git a/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml
index cb34018..bbd9da2 100644
--- a/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml
+++ b/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml
@@ -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
diff --git a/kafka-streams-samples/kafka-streams-word-count/src/test/java/kafka/streams/word/count/WordCountProcessorApplicationTests.java b/kafka-streams-samples/kafka-streams-word-count/src/test/java/kafka/streams/word/count/WordCountProcessorApplicationTests.java
index 17a19ea..4d79823 100644
--- a/kafka-streams-samples/kafka-streams-word-count/src/test/java/kafka/streams/word/count/WordCountProcessorApplicationTests.java
+++ b/kafka-streams-samples/kafka-streams-word-count/src/test/java/kafka/streams/word/count/WordCountProcessorApplicationTests.java
@@ -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);