Browse Source

KAFKA-7855: Kafka Streams Maven Archetype quickstart fails to compile out of the box (#6194)

Reviewers: Guozhang Wang <guozhang@confluent.io>, Matthias J. Sax <matthias@confluent.io>
pull/6452/head
Kristian Aurlien 6 years ago committed by Matthias J. Sax
parent
commit
fd5c0849e1
  1. 6
      streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java

6
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java

@ -44,9 +44,9 @@ public class LineSplit { @@ -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);

Loading…
Cancel
Save