こんな感じで書くと
streams-file-inputのデータを読んで、streams-wordcount-outputに結果を書いていくっぽい。こういう処理を触るのは初めてなんだけど、面白いなー。
こういうデータを食わせたら
all streams lead to kafka hello kafka streams join kafka summit
こうなった
all 1 streams 1 lead 1 to 1 kafka 1 hello 1 kafka 2 streams 2 join 1 kafka 3 summit 1
全然Kafka分かんないから色々はまったけど、動いてスッキリした記念にメモ。
ここを読みながらやったよ。
https://kafka.apache.org/documentation#quickstart_kafkastreams
はまったのは。あれ。Dockerで動かしてたからで。ローカルで動かしたらさらっとうごいた。
