[BEAM-744] UnboundedKafkaReader should return as soon as it can.

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.3.0-incubating
• Component/s: io-java-kafka
• Assignee: Amit Sela
• Reporter: Amit Sela
• Created: 12/Oct/16 20:30
• Updated: 16/May/20 13:57
• Resolved: 19/Oct/16 18:45

Description

KafkaIO has two "wait" properties:

START_NEW_RECORDS_POLL_TIMEOUT - wait for new records inside start(), default: 5 seconds.
NEW_RECORDS_POLL_TIMEOUT - wait for new records inside start(), default: 10 msec.

Instead, they should return as soon as they can, rangadi mentioned here: https://github.com/apache/incubator-beam/pull/1071 that they were both originally set to 10 milliseconds, so START_NEW_RECORDS_POLL_TIMEOUT should probably be re-set to 10 milliseconds.

Issue Links

• links to: GitHub Pull Request #1125