Система обмена сообщениями Pub-Sub для двусторонней связи

Question

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

Step 1: data from System is given to Publisher. 
Step 2: Publisher simply pushes the data to the Topic based Messaging 
        system.
Step 3: There will be  more than one subscribers for each topic and
        subscribers should get notified as soon there are some entries in
        messaging system. 
Step 4: Subscribers process the data and update the status back to messaging 
        system. 
Step 5: Publisher should get notified for the processed messages and 
        acknowledge the System which gave the data.

Итак, мой вопрос: могу ли я использовать RabbitMq или Kafka для «Системы обмена сообщениями на основе тем»? Мое главное требование - обновить статус от подписчиков, а издатель должен получить уведомление об обновлении статуса. (Меня не очень беспокоит пропускная способность, производительность, масштабируемость в этот момент времени). Еще одна моя проблема - восстановление данных / HA.

Answer 1

Как насчет системы тем N + 1, одной для публикации сообщений, которая будет использоваться N подписчиками, и N тем для подтверждений, по одной на подписчика. Ваша «Система» может подписаться на все эти темы подтверждения N и может проверить, все ли подписчики обработали оригинальное сообщение, которое было опубликовано производителем. Каждое сообщение в Кафке например. имеет ключ сообщения, и тот же ключ сообщения может использоваться для сопряжения исходного сообщения с подтверждением его подписчика.

Достигает ли это того, чего вы хотите в вашей системе?