Spring Cloud Stream 2.0 и последний запуск startOffset

Question

При обновлении нашего приложения до весенней загрузки 2.0.3 мы столкнулись с проблемой потребления сообщений и использования startOffset: latest,
Сценарий, который мы протестировали, выглядит следующим образом:

1. развернуть приложение с потребителем (topic = TEST_CHANNEL,group = kafka2_test), настроенным с startOffset: latest в pcf и увеличьте количество экземпляров до 5.
2. остановить приложение
3. опубликовать 40 сообщений в теме TEST_CHANNEL
4. запустить приложение

мы видим, что приложение успешно назначает разделы, однако некоторые экземпляры не используют те разделы, которым они назначены.
Мы также проверили это, проверив отставание для группы.
Этот сценарий работал при использовании весенней загрузки 1.5.10. Это также работало при использовании весенней загрузки 2.0.3 и не устанавливая startOffset: latest,

Примечание: это не новая группа, поэтому предполагается, что смещение присутствует для потребителя, и resetOffsets не должно иметь никакого эффекта.

Это проблема при загрузке весной 2.0.3?

Answer 1

не новая группа... и resetOffsets не должно иметь никакого эффекта.

resetOffsets специально предназначен для сброса смещения для существующей группы в startOffset значение.

Он был сломан в версии 1.3.x связующего (версия, используемая Boot 1.5.x) и не имел никакого эффекта.