CODEWITHSUNDEEP
apache-kafkakafka-consumer-api
BdEngineer
BdEngineer

Reputation: 3209

Kafka: how to fix the issue of corrupt offsets, and how to manually reset the offset of consumer to read again?

How to fix the issue of corrupt offsets, and how to manually reset the offset of consumer to read again?

I am not sure how to do it manually in the code.

Upvotes: 0

Views: 1459

Answers (1)

Katya Gorshkova
Katya Gorshkova

Reputation: 1561

You can set position of the consumer manually by calling KafkaConsumer.seek(TopicPartition partition, long offset) method.

Upvotes: 1

Related Questions