Доброго. Spring boot + kafka consumer api. пытаюсь отмотать очередь на начало.

Question

Доброго. Spring boot + kafka consumer api. пытаюсь отмотать очередь на начало.

говорят, что перед перемоткой нужно получить партиции, которым можно выставить смещение, т.е. сделать:
consumer.poll(Duration.ZERO)
не перематывается - не возвращает сообщения (про повторном poll). но если выполнить с бОльшим таймаутом:
consumer.poll(Duration.ofMillis(1000))
то перематывается, сообщения получаю.
почему с 0-ым таймаутом не работает?

#kafka #russian #software

0

03.02.2021

2 ответов

11 просмотров

Nikolaj Rudakov Автор вопроса

Ринат Харисов
из доков KafkaConsumer > This method returns imme...

> Note, that seekXXX() can only be used after a consumer joined a group -- thus, it's required to do a "dummy-poll" before using seekXXX()

0

03.02.2021

Ринат Харисов · Accepted Answer

Ринат Харисов

из доков KafkaConsumer > This method returns immediately if there are records available. Otherwise, it will await the passed timeout. If the timeout expires, an empty record set will be returned.

0

03.02.2021

52 похожих чатов

Доброго. Spring boot + kafka consumer api. пытаюсь отмотать очередь на начало.

2 ответов

Похожие вопросы