本文共 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转载地址:http://ufzqj.baihongyu.com/