apache-kafka - Kafka：如何解决损坏偏移的问题，以及如何手动重置消费者的偏移以再次读取？

Question

如何解决损坏偏移的问题，以及如何手动重置消费者的偏移以再次读取？

我不确定如何在代码中手动执行。

标签： apache-kafkakafka-consumer-api

Answer 1

KafkaConsumer.seek(TopicPartition partition, long offset您可以通过调用) 方法手动设置消费者的位置。