Versions Compared

Key

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

...

Current state"Under Discussion"

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

JIRA: here [Change the link from KAFKA-1 to your own ticket]

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

...

There's no impact on existing users as we only add new method. End users who leverages `poll(0)` are encouraged to migrate to the new method with proper timeout (and retry), as it provides expected behavior with avoiding infinite hang.

Rejected Alternatives

Add overloaded version of `poll(Duration, Duration)` to provide timeout for both updating assignment metadata and pulling records

While this method helps to achieve similar effect on `poll(0)`, this still doesn't guarantee the desired behavior - no records will be polled. As end users only interest with assignment metadata when they call `pull(0)`, it would be better to provide a method which guarantee such behavior.