You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2019/03/16 02:55:28 UTC

[kafka] branch 2.0 updated: KAFKA-7855: Kafka Streams Maven Archetype quickstart fails to compile out of the box (#6194)

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.0 by this push:
     new b0132fb  KAFKA-7855: Kafka Streams Maven Archetype quickstart fails to compile out of the box (#6194)
b0132fb is described below

commit b0132fbbb52dfe6375851e09b25dc5398700ce83
Author: Kristian Aurlien <au...@users.noreply.github.com>
AuthorDate: Sat Mar 16 03:51:20 2019 +0100

    KAFKA-7855: Kafka Streams Maven Archetype quickstart fails to compile out of the box (#6194)
    
    Reviewers: Guozhang Wang <gu...@confluent.io>, Matthias J. Sax <ma...@confluent.io>
---
 .../main/resources/archetype-resources/src/main/java/LineSplit.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java b/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java
index bbf54e6..d712a83 100644
--- a/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java
+++ b/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java
@@ -44,9 +44,9 @@ public class LineSplit {
 
         final StreamsBuilder builder = new StreamsBuilder();
 
-        builder.stream("streams-plaintext-input")
-               .flatMapValues(value -> Arrays.asList(value.split("\\W+")))
-               .to("streams-linesplit-output");
+        builder.<String, String>stream("streams-plaintext-input")
+            .flatMapValues(value -> Arrays.asList(value.split("\\W+")))
+            .to("streams-linesplit-output");
 
         final Topology topology = builder.build();
         final KafkaStreams streams = new KafkaStreams(topology, props);