logstash kafka 출력 (json 데이터 전송)

Question

logstash에서 데이터를 kafka 및 ES로 보내려고합니다. ES에서 데이터는 rubydebug (기본적으로 json 데이터는 필터를 적용하고 새 필드를 추가 한 후)와 같은 형식으로 전송됩니다. 같은 데이터를 카프카에게 보내고 싶습니다. 그러나 logstash는 원본 메시지 만 kafka로 보냅니다. (나는 원래 메시지를 변형하지 않는다).

동일한 데이터를 ES로 보내는 카프카 (json 형식)로 보낼 수 있습니까?

Answer 1

kafka {} 출력에 codec => "json"을 설정하면 찾고있는 것을 제공 할 가능성이 높습니다. 기본값은 '일반'이며 서식을 지정하지 않습니다.