logstash kafka出力（jsonデータ送信）

Question

logstashでは、私はkafkaとESにデータを送信しようとしています。 ESでは、データはrubydebug（基本的にはフィルタを適用して新しいフィールドを追加した後のjsonデータ）で示されているのと同じフォーマットで送られます。同じデータをkafkaに送信したい。しかし、logstashは元のメッセージだけをkafkaに送信します。 （私は元のメッセージを変更していません）。

私たちがESに送るカフカ（json形式）に同じデータを送ることはできますか？

Answer 1

kafka {}出力にcodec => "json"を設定すると、探しているものが表示される可能性があります。デフォルトは 'plain'で、書式設定は行われません。