我们正在使用水槽，我需要将一些日志消息收集到 rabbitmq 中。我找到了一个从rabbitmq读取消息的源实现，但是我找不到可以将消息写入rabbit的接收器。所以我想自己写一个。查看像logsandra这样的示例实现让我觉得应该不会太难。
但是我找不到任何关于如何编写自定义接收器的文档。我没有找到用于水槽罐的 maven 存储库，也没有找到有关如何部署自定义接收器的设置说明。
任何人都可以分享他的经验，或者更好的是，将我指向现有的教程。
问问题
4246 次
1 回答
8
最终我们自己写了一个，并将其开源 - https://github.com/kenshoo/flume-rabbitmq-sink
现在有一个cloudera repo https://ccp.cloudera.com/display/CDHDOC/Using+the+CDH3+Maven+Repository（我问的时候没有）
Flume 用户指南现在很好地解释了如何配置自定义插件
于 2011-11-23T19:39:40.023 回答