нам нужно построить фасад REST поверх API запросов / ответов Kafka (две отдельные темы), который поддерживает несколько одновременных клиентов, поэтому должна быть возможность демультиплексировать ответы и направить их обратно в ожидающий поток / вызывающего абонента. Мы используем Spring Kafka
Spring предоставляет ReplyingKafkaTemplate, который поддерживает несколько клиентов через их выделенные разделы. Проблема, однако, заключается в том, что я полагаю, что этого не хватает в случае перебоев с клиентами и последующей (недетерминированной c) перебалансировки клиентов. В этом случае не только корреляции от (мертвого) клиента будут потеряны (что не является проблемой), но и назначение разделов для других исправных клиентов также изменится при условии автоматического c назначения разделов.
конечно, мы можем использовать статическое / ручное назначение, но это тоже кажется «хакерским» решением.
С внешними хранилищами состояний (база данных) проблема заключается в том, что клиентам придется постоянно опрашивать, чтобы быть в курсе входящие ответы, которые звучат несколько уродливо.
очень заинтересованы в любых указателях, спасибо