У меня мало сомнений насчет весеннего облачного потока (используя Кафку) ....
- Есть ли у Spring Cloud Stream какой-либо способ написать потребителя, который может перебирать все сообщения в теме? [это в основном необходимо для проверки, чтобы в очередь kafka не записывались повторяющиеся сообщения] и
- как насчет поддержки Future / sync в весеннем облачном потоке, как в spring-kafka.
Если кто-либо сталкивался с подобным сценарием, можете ли вы предоставить некоторые подробности о том, как его достичь? или я должен использовать зависимость spring-kafka (делается с помощью spring-kafka) параллельно с spring-cloud-stream для достижения.
если есть какой-либо рабочий код или URL, пожалуйста, предоставьте. это будет очень полезно.
Заранее спасибо