我已经通过命令“gem install fluent plugin kafka”为我的fluentd安装了output\u kafka插件。
但当我启动fluentd服务时，我在日志文件中收到了以下错误消息：
2012-11-09 18:18:39+0800:刷新缓冲区暂时失败，下次重试时间为2012-11-09 18:52:46+0800。error=“uninitialized constant kafka:：message”示例=69952455476860
似乎output_kafka.rb找不到模块kafka或类消息，如何修复？
1条答案
按热度按时间wxclj1h51#
我是卡兹，弗伦特的委员。这听起来像是Kafka的错误。你能从这里报告这个bug吗，还有你的环境描述？
https://github.com/kiyoto/fluent-plugin-kafka/issues
你一报完，我就去看看。谢谢-k