Мы используем flume, и мне нужно собрать несколько лог-сообщений в rabbitmq. Я нашел источник реализации , который читает сообщения из rabbitmq, но я не смог найти приемник, который может писать сообщения в кролика. Так что я подумал написать сам. Глядя на примеры реализации, такие как logsandra , я понял, что это не должно быть слишком сложно.
Однако я не смог найти никакой документации о том, как написать собственный приемник.
Я не нашел репозитория Maven для банок с дымоходом или инструкций по установке для развертывания пользовательского приемника.
Может кто-нибудь поделиться своим опытом или, что лучше, указать мне на существующий учебник.