如何编写定制水槽OG水槽

Question

我们正在使用水槽,我需要收集一些日志消息到rabbitmq.我找到了一个从rabbitmq读取消息的源实现,但我找不到可以将消息写入Rabbit的接收器.所以我在想自己写一个.看看像logsandra这样的示例实现让我觉得它应该不会太难.

但是我找不到任何关于如何编写自定义接收器的文档.我没有找到水槽罐的maven回购,或者有关如何部署自定义接收器的设置说明.

任何人都可以分享他的经验,或者更好,指出我现有的教程.

Answer 1

最终我们自己写了一个,并开源了它 - https://github.com/kenshoo/flume-rabbitmq-sink

而flume用户指南现在解释了如何配置自定义插件