Использование ReplyingKafkaTemplate в двух разных приложениях

Question

У меня есть приложение весенней загрузки1, которое отправляет сообщение на request topi c. При получении этого сообщения другое приложение весенней загрузки2 потребляет сообщение, обрабатывает и отправляет ответ в response topi c. Могу ли я использовать replying-template в application1 для этой интеграции. В приложении2 нужно ли вносить изменения, чтобы корреляция отправлялась обратно при отправке ответа в приложении2?

Answer 1

Если application2 использует @KafkaListener с не возвращаемым типом возврата, адаптер прослушивателя позаботится об идентификаторе корреляции.

Если это void @KafkaListener и вы отправляете ответ с KafkaTemplate (или каким-либо другим способом), тогда, да, вам нужно распространить заголовок идентификатора корреляции из входящего сообщения в ответ.