[Logstash] Kafka 연동 시 쉽게 디버깅 하기.
Elastic/Logstash 2016. 4. 14. 11:26그냥 들어가고 나오고가 잘되는지 보기 위한 logstash input/output config 입니다.
별것도 아니지만 늘 구글링 하기도 귀찮고 해서 기록해 봅니다.
참고문서)
https://www.elastic.co/blog/logstash-kafka-intro
https://www.elastic.co/guide/en/logstash/current/plugins-outputs-kafka.html
https://www.elastic.co/guide/en/logstash/current/plugins-inputs-kafka.html
Logstash Output Kafka - Producer)
$ bin/logstash -e "input { stdin {} } output { kafka { bootstrap_servers => '172.x.x.x:9024' topic_id => 'logstash_logs' } }"
Logstash Input Kafka - Consumer)
$ bin/logstash -e "input { kafka { zk_connect => '172.x.x.x:2181' topic_id => 'logstash_logs' } } output { stdout { codec => rubydebug } }"