我们正在使用flume，我需要将一些日志消息收集到rabbitmq中。我找到了一个从rabbitmq读取消息的源实现，但找不到一个可以将消息写入rabbit的接收器。所以我想自己写一本。看着像logsandra这样的示例实现，我觉得应该不会太难。但是，我找不到任何关于如何编写自定义接收器的文档。我没有为flume jar找到maven repo，也没有关于如何部署定制Flume的设置说明。有谁能分享他的经验，或者更好的，给我指一个现有的教程。
1wnzp6jl1#
最终我们自己写了一个，并且开源了它-https://github.com/kenshoo/flume-rabbitmq-sink现在有cloudera回购https://ccp.cloudera.com/display/cdhdoc/using+the+cdh3+maven+repository （我问的时候没有）flume用户指南现在很好地解释了如何配置自定义插件http://archive.cloudera.com/cdh/3/flume/userguide/index.html#_extending_via_sink_source_decorator_plugins
1条答案
按热度按时间1wnzp6jl1#
最终我们自己写了一个，并且开源了它-https://github.com/kenshoo/flume-rabbitmq-sink
现在有cloudera回购https://ccp.cloudera.com/display/cdhdoc/using+the+cdh3+maven+repository （我问的时候没有）
flume用户指南现在很好地解释了如何配置自定义插件
http://archive.cloudera.com/cdh/3/flume/userguide/index.html#_extending_via_sink_source_decorator_plugins