Тебе их надо как то хитро пинить на конкретные инстансы, чтобы сообщение выбрасывалось после чтения, на основе рассчета хэшей по какому то свойству и отдельно иметь список доставленных сообщений и прикручивать механизм ретраев для повисших сообщений - но это их надо где то хранить, ты возвращаешься к модели с единой точкой отказа
Спасибо)
Вообще думал к каждому инстансу прикрутить бд и писать в нее сразу сконсьюменные сообщения.
А потом для каждого клиента запрашивать сообщения из бд. Тогда я смогу быстро читать сообщения и персистентное хранилище будет на случай падения сервиса. Как считаешь норм будет?
На быстроту забиваем.