KTable<String, Long> wordCounts = textLines .flatMapValues(textLine -> Arrays.asList(textLine.toLowerCase()
                                                    .split("\\W+")))
                                                    .groupBy((key, word) -> word)
                                                    .count(Materialized.<String, Long, KeyValueStore<Bytes, byte[]>>as(
                                                            "counts-store"));