#apache-kafka
#apache-kafka
Вопрос:
Как я могу перейти к следующей позиции смещения, игнорируя текущую позицию. В настоящее время я использую ‘seektoend()’, но хочу использовать что-то, что переходит к следующему смещению, а не к концу.
Комментарии:
1. с помощью seek(). —> искать (раздел, currentOffset 1)
2. Извлекается ли текущая позиция смещения с помощью position()?
3. Текущая позиция будет указана ConsumerRecord благодаря его методу offset(). kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/…
4. Но если у меня нет доступной записи ConsumerRecord?
5. используйте одно сообщение, чтобы затем получить смещение.