mwsbkru/broker-bridge

broker-bridge's Issues

Реализовать поддержку нескольких мостов

Подготовить тестовое окружение с кафками

Подготовить docker-compose с тремя кафками и инструменты, позволяющие засылать данные во все три кафки и вычитывать из них данные. Также необходимо подготовить скрипты с короткими алиасами для команд.

Релизовать поддержку нескольких брокеров-приемников в рамках одного моста

Реализовать корректную поддержку SIGINT для закрытия всеоткрытых соединений с брокерами

Распараллелить отправку сообщений в несколько приемников

Вынести отправку сообщения в брокер-приемник в горутину

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

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

Реализовать проброс сообщений, анагогичный Кафке для Rabbit MQ

Приступать к реализации этой задачи после закрытия всех задач по Кафке первой очереди