syossan https://blog.hatena.ne.jp/syossan/ 生涯未熟 https://syossan.hateblo.jp/ 最近、Apache財団に囲まれながらアレコレやってる私です。 今回はfluentdのkafkaプラグインであるfluent-plugin-kafkaを使って、kafka streamsが出来なかったお話をば。 何をしたかったのか fluentdでログを監視しつつ、変更があればfluent-plugin-kafkaを使いkafka brokerへログ内容をメッセージとして飛ばす。 そして、kafka streamsでメッセージを加工し、改めてログとして保存するということを実現しようとしていました。 一体何が起こったのか 実際に、この構成で組んでみたのですがkafka streamsを動かしてみる… 190 <iframe src="https://hatenablog-parts.com/embed?url=https%3A%2F%2Fsyossan.hateblo.jp%2Fentry%2F2017%2F08%2F25%2F112532" title="fluent-plugin-kafkaを使ってkafka streamsでアレコレするのはまだ出来ないよという話 - 生涯未熟" class="embed-card embed-blogcard" scrolling="no" frameborder="0" style="display: block; width: 100%; height: 190px; max-width: 500px; margin: 10px 0px;"></iframe> Hatena Blog https://hatena.blog 2017-08-25 11:25:32 rich https://syossan.hateblo.jp/entry/2017/08/25/112532 1.0 100%