Logstash之四：logstash接收kafka数据
Posted 学无止境
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Logstash之四：logstash接收kafka数据相关的知识，希望对你有一定的参考价值。
3、kafka+logstash整合
logstash1.5以后已经集成了对kafka的支持扩展，可以在conf配置中直接使用
vim /etc/logstash/conf.d/pay.conf
input {
kafka{
zk_connect => "your zookeeper address:2181"
group_id => "logstash"
topic_id => "pay-replicated"
reset_beginning => false
consumer_threads => 5
decorate_events => true
}
}
output {
# stdout{ codec=> rubydebug }
redis {
host => ["your redis address:6380"]
batch => true
key => "logstash-nginx-pay-replicated"
data_type => "list"
}
}
重启logstash
service logstash restart
以上是关于Logstash之四：logstash接收kafka数据的主要内容，如果未能解决你的问题，请参考以下文章