- целесообразность и оверинжинирг. я бы точно так не стал так делать, для этого нужны какие-то веские по более "ну может потом это всё будет асинхронно".
и, кстати, каким боком здесь Kafka Stream появился?
Да, реализация сложная. Kafka Steam появился потому что на стриме есть метод filter , который как раз позволит найти нужное сообщение
фильтр по correlationId? у мне нет какого-то релевантного опыта по Kafka Stream, но подозреваю, что так не делают :). скорее у сервиса, который держит http-соединения должна быть в памяти таблица соответствия соединения своему correlationId и фильтрация будет уже по этой таблице
Фильтрация топика для поиска нужного сообщения, это один из подходов. У него есть недостатки, так как приходится фильтровать большое количество сообщений. Но у меня вопрос создание короткоживущих консьюмеров или стримов, на каждый запрос. Насколько это затратно с точки зрения ресурсов Кафки.
Обсуждают сегодня