provide a streams-like example for doing word-count maybe? KStream<String, String> textLines = builder.stream(“quickstart-events”);

KTable<String, Long> wordCounts = textLines .flatMapValues(line -> Arrays.asList(line.toLowerCase().split(" “))) .groupBy((keyIgnored, word) -> word) .count();

wordCounts.toStream().to(“output-topic”, Produced.with(Serdes.String(), Serdes.Long()));