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 <aurl...@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 <guozh...@confluent.io>, Matthias J. Sax <matth...@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);