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:53:19 UTC
[kafka] branch 2.2 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.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.2 by this push:
new e7ec053 KAFKA-7855: Kafka Streams Maven Archetype quickstart fails to compile out of the box (#6194)
e7ec053 is described below
commit e7ec05381f57129e1a1a18bd2a3e732cc32456d6
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);