2 Услуги: и b
- api api для внешних клиентов. requests and ResponseTopic to push the results of the request
- External client calls A via Rest sync call
- A sends message to topic RequestTopic via ReplyingKafkaTemplate and suspends thread in waiting state
- B get message from RequestTopic, processes it and sends response to ResponseTopic
- A consumes response, correlates it with the request's waiting thread and A returns http response to client
Проблема существует в кластере. Если у нас есть несколько реплик-запрос на p.1 может быть отправлен из одного экземпляра приложения, и ответ может быть использован другим экземпляром приложения в группе потребителей. < /P>
Документация Spring Kafka предлагает использовать какую-то привязку распределения потребителей, где требование должна знать, что идентификатор точного разделения и поставить раздел «Неблуник», но и в ответ на этот вопрос, но и в Spected Pregite-Partition, но и в этом ответе. Мнение - мы не можем масштабировать развертывание приложения динамически без реконфигурирования разделов и потребителей. Другие случаи просто пропустят это сообщение.
Это решение также выглядит не очень хорошо, потому что многие сообщения будут обработаны напрасными. < /P>
Любые другие идеи, как его решить?
Подробнее здесь: https://stackoverflow.com/questions/796 ... katemplate
