本文共 464 字，大约阅读时间需要 1 分钟。

fluent-plugin-kafka (0.6.6)

ruby-kafka (0.4.4)

在使用fluentd中使用 kafka source

会出现问题 默认会安装 fluent-plugin-kafka (0.6.6) ruby-kafka (0.5.2)

但是测试发现会出现若干问题

ruby-kafka 说明中指出支持kafka0.9

不过下了相关tag版本的ruby-kafka 在ruby-mine 中运行发现只有0.4.4是支持kafka0.9 consumer

td-agent-gem install fluent-plugin-kafka –version 0.6.6

td-agent-gem install ruby-kafka -v 0.4.4 td-agent-gem uninstall ruby-kafka –version 0.5.2

td-agent-gem list | grep kafka

fluent-plugin-kafka (0.6.6)

ruby-kafka (0.4.4)

转载地址：http://ufzqj.baihongyu.com/