Micah Whitacre created CRUNCH-621: ------------------------------------- Summary: Kafka no data to consume could get stuck Key: CRUNCH-621 URL: https://issues.apache.org/jira/browse/CRUNCH-621 Project: Crunch Issue Type: Bug Components: IO Reporter: Micah Whitacre
With the KafkaSource and specifically the KafkaRecordReader, if there is no data to consume from a partition because all data fell off Kafka then we can end up in a situation where the KafkaRecordReader will poll forever as it never gets data to reach its ending offset. -- This message was sent by Atlassian JIRA (v6.3.4#6332)