How to write a regular OG downpipe

We use a tray, and I need to collect some log messages in rabbitmq. I found a source implementation that reads messages from rabbitmq, but I could not find a receiver that could write messages to rabbitmq. So I thought about writing myself. Looking at implementation examples like logsandra made me think that it shouldn't be too complicated.

However, I could not find any documentation on how to write a custom shell. I did not find a maven repo for flux banners or installed instructions on how to deploy a custom shell.

Can someone share their experience or, better, point me to an existing textbook.

+4
source share
1 answer

In the end, we wrote one and opened it - https://github.com/kenshoo/flume-rabbitmq-sink

there is cloudera repo now https://ccp.cloudera.com/display/CDHDOC/Using+the+CDH3+Maven+Repository (not when I asked)

And the flume user guide now explains how to set up a custom plugin

http://archive.cloudera.com/cdh/3/flume/UserGuide/index.html#_extending_via_sink_source_decorator_plugins

+8
source

All Articles