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. publish40 сообщений в теме TEST_CHANNEL
4. запуск приложения

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

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

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

Answer 1

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

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

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