Обработка нескольких ответов с помощью ReplyingKafkaTemplate - PullRequest
0 голосов
/ 14 марта 2019

Я пытаюсь реализовать шаблон ответа, в котором я публикую сообщение в теме, которую слушают несколько групп потребителей.Это означает, что все они получат сообщение, а также отправят ответ в теме ответа.

Проблема заключается в том, что все они отвечают на одно и то же сообщение, и только первое полученное сообщение в теме ответа должно быть получено.,Остальные будут сброшены.Учитывая, что я знаю, сколько ответов я должен получить по теме ответа (позвоните по номеру n), как я могу заставить ReplyingKafkaTemplate ждать n ответов и затем разрешать ответ?Я попытался сделать вывод из Spring Kafka документации , но не смог понять это.Спасибо.

1 Ответ

1 голос
/ 14 марта 2019

Этот шаблон предназначен исключительно для обработки одного запроса / ответа.

Вы не можете использовать его для своего варианта использования.

Используйте KafkaTemplate и отдельного слушателя; вам придется сопоставлять ответы самостоятельно.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...