我們使用水槽,我需要收集一些日誌消息到rabbitmq。我發現了一個從rabbitmq讀取消息的源implementation,但我找不到可以將消息寫入兔子的接收器。所以我正在考慮自己寫一個。看看logsandra這樣的示例實現讓我覺得它不應該太難。如何編寫自定義水槽OG水槽
但是我找不到有關如何編寫自定義接收器的任何文檔。 我沒有找到水槽罐子的maven回購,或者關於如何部署定製水槽的設置說明。
任何人都可以分享他的經驗,或更好的,指向我現有的教程。
我們使用水槽,我需要收集一些日誌消息到rabbitmq。我發現了一個從rabbitmq讀取消息的源implementation,但我找不到可以將消息寫入兔子的接收器。所以我正在考慮自己寫一個。看看logsandra這樣的示例實現讓我覺得它不應該太難。如何編寫自定義水槽OG水槽
但是我找不到有關如何編寫自定義接收器的任何文檔。 我沒有找到水槽罐子的maven回購,或者關於如何部署定製水槽的設置說明。
任何人都可以分享他的經驗,或更好的,指向我現有的教程。
最後,我們寫了一個自己,開源了它 - https://github.com/kenshoo/flume-rabbitmq-sink
有一個Cloudera的回購現在https://ccp.cloudera.com/display/CDHDOC/Using+the+CDH3+Maven+Repository(有沒有當我問)
和料槽用戶指南現在很好地解釋瞭如何配置自定義插件