Помогите разобраться. есть публичная очередь. из нее читаются сообщения. как

Question

pro.kafka

Пользователь 616b0

Помогите разобраться. есть публичная очередь. из нее читаются сообщения. как

мне получить максимальный офсет в очереди? чтобы я с него начал читать. offsetfetch response приходит пустым.

#kafka #russian #software

0

03.06.2020

1 ответов

9 просмотров

Andrey · Accepted Answer

auto.offset.reset This property controls the behavior of the consumer when it starts reading a partition for which it doesn’t have a committed offset or if the committed offset it has is invalid (usually because the consumer was down for so long that the record with that offset was already aged out of the broker). The default is “latest,” which means that lacking a valid offset, the consumer will start reading from the newest records (records that were written after the consumer started running). The alternative is “earliest,” which means that lacking a valid offset, the consumer will read all the data in the partition, starting from the very beginning. Setting auto.offset.reset to none will cause an exception to be thrown when attempting to consume from invalid offset.

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

Помогите разобраться. есть публичная очередь. из нее читаются сообщения. как

1 ответов

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