Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Table of Contents

Status

Current state: Under Vote Accepted

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

Vote thread: here 

JIRA:  KAFKA-5682

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

Code Block
while (true) {
    try {
        consumer.poll(Duration.ofMillis(50));
    } catch (RecordDeserializationException e) {
        consumer.seek(tpe.partition(), e.offset() + 1);
    }
}


Compatibility, Deprecation, and Migration Plan

...