СКС Кафка, потребитель обрабатывает только последние сообщения

Я использую SCS 1.3.0.RELEASE. У меня есть производитель и потребитель приложений. Не запуская потребительское приложение, я использовал приложение-производитель для отправки нескольких сообщений. Затем запустил потребительское приложение, но сообщения не были использованы. Когда оба истекли, потребительское приложение обрабатывается правильно.

1 ответ

Решение

Если потребитель не имеет spring.cloud.stream.<...>.group свойство, потребление начнется в конце темы по умолчанию.

Добавить группу.

Другие вопросы по тегам