2011-07-06 3 views
4

Nous utilisons un canal et j'ai besoin de collecter des messages de log dans rabbitmq. J'ai trouvé une source implementation qui lit des messages de rabbitmq, mais je n'ai pas pu trouver un évier capable d'écrire des messages dans lapin. Donc je pensais en écrire un moi-même. En regardant des exemples d'implémentations comme logsandra, j'ai pensé que ça ne devrait pas être trop difficile.Comment écrire un évier OG de canal personnalisé

Cependant, je n'ai trouvé aucune documentation sur la façon d'écrire un lavabo personnalisé. Je n'ai pas trouvé de repo maven pour les jarres de canal, ni d'instructions de configuration pour déployer un récepteur personnalisé. Est-ce que quelqu'un peut partager son expérience, ou mieux, me diriger vers un tutoriel existant.

Répondre

8

Finalement, nous avons écrit un nous-mêmes, et ouvert le code source, il - https://github.com/kenshoo/flume-rabbitmq-sink

il y a une prise en pension de Cloudera maintenant https://ccp.cloudera.com/display/CDHDOC/Using+the+CDH3+Maven+Repository (il n'y avait pas quand j'ai demandé)

et guide utilisateur flume explique maintenant bien comment configurer un plugin personnalisé

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

Questions connexes