我已经通过命令“gem install fluent-plugin-kafka”为我的 fluentd 安装了 output_kafka 插件。
但是当我启动 fluentd 服务时,我在日志文件中收到以下错误消息:
2012-11-09 18:18:39 +0800: 暂时刷新缓冲区失败,下次重试将在 2012-11-09 18:52:46 +0800。error="未初始化常量Kafka::Message " 实例=69952455476860
似乎 output_kafka.rb 找不到模块 Kafka 或类消息,那么我该如何解决呢?