CODEWITHSUNDEEP
apache-kafkakafka-consumer-api
Mazen Ezzeddine
Mazen Ezzeddine

Reputation: 822

Kafka *Offset* exceptions

The kafka exceptions NoOffsetForPartitionException and OffsetOutOfRangeException are Thrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured.

Can you describe execution scenarios that cause these exceptions to be raised?

Thank you.

Upvotes: 1

Views: 894

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191671

One example - consumer.seek is called for a partition offset that doesn't exist.

Other example - a consumer group was paused for some long duration, then resumes after its stored offsets have been deleted due to topic retention policies. In this case, the auto.offset.reset policy is taken into account to either seek to the latest/earliest available offset.

Upvotes: 1

Related Questions