KafkaStreamsを触ってみた

こんな感じで書くと

gist.github.com

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で動かしてたからで。ローカルで動かしたらさらっとうごいた。