Как прослушать правильное сообщение ACK от Kafka

jabrena спросил: 26 декабря 2017 в 08:06 в: spring-boot

Я делаю POC с Spring Boot & Кафка для транзакционного проекта, и у меня есть следующие сомнения:

Сценарий: Один микросервис MSPUB1 получает запросы от клиента. Этот запрос публикует сообщение на тему TRANSACTION_TOPIC1 на Kafka, но Microservice может получать несколько запросов параллельно. Microservice прослушивает тему TRANSACTION_RESULT1 , чтобы проверить завершение транзакции.

На другой стороне потоковой платформы другой Microservice MSSUB1 прослушивает тему TRANSACTION_TOPIC1 и обрабатывать все сообщения и публиковать результаты по адресу: TRANSACTION_RESULT1

Каков наилучший способ из MSPUB1 , чтобы узнать, сообщение по теме TRANSACTION_RESULT1 соответствует его первоначальному запросу? Микросервис MSPUB1 может иметь идентификатор для любого сообщения, опубликованного в начальном разделе TRANSACTION_TOPIC1 и перемещаться в TRANSACTION_RESULT1

Вопрос: Когда вы читаете раздел, вы перемещаете указатель, но в среде параллелизма с несколькими запросами, как проверить, является ли сообщение в теме TRANSACTION_RESULT1 ожидаемым?

Большое спасибо заранее

Хуан Антонио


0 ответов