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