mq-kafka

Микросервис надежной очереди сообщений для Kafka, реализованный с использованием последней версии стека технологий Spring Cloud.

При отправке сообщений используется механизм компенсации, что позволяет продолжать отправку сообщений даже в случае простоя сервиса, обеспечивая надежность сообщений.

При получении сообщений используется многопоточная модель, которая разделяет потоки приема сообщений и потоки выполнения бизнес-логики.

Используемые технологии:

Spring Cloud

Redis

ZooKeeper (кластер)

Kafka (кластер)

MongoDB (кластер с репликацией и шардингом)

Скрипты для развертывания и настройки кластера прилагаются