如何使用 fluentd output_kafka 插件？答案

【问题标题】：How to use fluentd output_kafka plugin?如何使用 fluentd output_kafka 插件？
【发布时间】：2012-11-09 10:45:00
【问题描述】：

我已经通过命令“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" instance=69952455476860

好像 output_kafka.rb 找不到模块 Kafka 或类 Message，我该如何解决呢？

【问题讨论】：

【解决方案1】：

我是 Kaz，Fluentd 提交者。这听起来像是 fluent-plugin-kafka 的错误。您能从这里报告错误，并附上您的环境描述吗？

https://github.com/kiyoto/fluent-plugin-kafka/issues

一旦你报告了，我会看看它。谢谢-K

【讨论】：