не воспроизводится на локальной машине.
* имеется топик, консумеров в данный момент нет
* производим N сообщений в топик
* запускаем консумер consumer.poll(TIMEOUT) - выходит пустой по таймауту.
* проверяем endOffsets - соответствует количеству произведенных сообщений, проверяем committed и position - они равны и меньше чем endOffsets (и соответствуют предыдущему запуску этого консумера).
То есть с моей точки зрения - потребитель должен все-таки потреблять, но он этого не делает.
*но* если произвести что-то в топик пока консумер жив - он оживает и все консумит, причем начинает с нужной позиции.
Это у меня какое-то концептуальное непонимание или?
в тестах надо несколько раз поллить - так уж работает консьюмер
Offset reset policy latest и консьюмер прочитает с самого начала а не с момента когда он ожил
Обсуждают сегодня