Я использую Spring Cloud Stream с брокером сообщений Kafka в моем Java-приложении. Я использую микросервисную архитектуру с тремя различными темами Кафки. Все работает нормально, но если какой-либо из микросервисов не работает и за это время некоторые сообщения создаются по определенной теме, значит, после того, как микросервис работает, я не могу прослушать последнее созданное сообщение.
Я решил проблему, добавив свойство start-offset spring.cloud.stream.kafka.bindings.input.consumer.start-offset = самое раннее
Но в этом случае послемодуль микросервиса запущен, он начинает искать сообщения сначала, он заставит потребителя заполняться старыми сообщениями несколько раз, хотя я получил желаемый результат.
Пожалуйста, кто-нибудь может сказать мне, после модуля микросервисавверх, мне нужно использовать последнее сообщение, созданное по конкретной теме .ie)
Микросервис 1: выдано несколько сообщений по определенной теме (когда микросервис 2 не работает) Микросервис 2: не прослушивается ни одна темапотому что он не работает
После того, как модуль активирован, Microservice 2: необходимо прослушать последний произведенныйсообщение (Микросервис 1) и выполнить обработку (как часть старого запроса, без необходимости нового запроса)