Skip to:

  1. Skip to Jira Navigation
  2. Skip to Side Navigation
  3. Skip to Main Content

KafkaConsumerFlowlet 0.7 does not handle OffsetOutOfRangeException correctly

Description

When OffsetOutOfRangeException occurs, the 0.7 consumer does not identify it correctly, and handle it. Instead the exception gets propagated, and the next fetch happens at the same invalid offset.

If handled properly, the offset should either get set to earliest or latest depending on whether the current offset is lesser than earlier offset or not.

Release Notes

None

Activity

Show:

Poorna Chandra February 12, 2015 at 10:38 PM

Poorna Chandra February 11, 2015 at 8:39 AM

Fixed
Pinned fields
Click on the next to a field label to start pinning.

Details

Assignee

Reporter

Labels

Affects versions

Components

Fix versions

Priority

Created February 11, 2015 at 5:24 AM
Updated March 4, 2016 at 1:28 AM
Resolved February 11, 2015 at 8:40 AM
Configure