Simplified/Clearified DSL-usage

diff --git a/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
index 524860977e15dfed0a1b9a8af0061f08b4ff851b..1ca5436210ed9ed1ac9862db1cc76cbbb04893af 100644 (file)
--- a/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
@@ -36,8 +36,8 @@ public class CounterStreamProcessor
        {
                StreamsBuilder builder = new StreamsBuilder();
 
-               KStream<String, String> source = builder.stream(properties.getInputTopic());
-               source
+               builder
+                               .<String, String>stream(properties.getInputTopic())
                                .map((username, word) ->
                                {
                                        try