Я бы предложил использовать Kafka, так как он имеет механизм отказоустойчивости, и даже если какое-либо сообщение потеряно или не перехвачено каким-либо слушателем, вы можете легко получить его из кластера Kafka.
Наряду с этим вы можете легко добавитьновый слушатель / слушатель в группе и kafka вместе с zookeeper позаботятся об управлении им очень хорошо.
Таким образом, Kafka - это распределенная система обмена сообщениями с подпиской на публикации, которая разработана для быстрой, масштабируемой и долговечной работы.Как и многие системы обмена сообщениями с публикацией и подпиской, Kafka поддерживает потоки сообщений в темах.Производители пишут данные по темам, а потребители читают по темам.
Очень просто для интеграции.