Rajini Sivaram created KAFKA-12268:
--------------------------------------
Summary: System tests broken because consumer returns early
without records
Key: KAFKA-12268
URL: https://issues.apache.org/jira/browse/KAFKA-12268
Project: Kafka
Issue Type: Bug
Components: consumer
Reporter: Rajini Sivaram
Assignee: Rajini Sivaram
Fix For: 2.8.0
https://issues.apache.org/jira/browse/KAFKA-10866 added metadata to
ConsumerRecords. We add metadata even when there are no records. As a result,
we sometimes return early from KafkaConsumer#poll() with no records because
FetchedRecords.isEmpty returns false if either metadata or records are
available. This breaks system tests which rely on poll timeout, expecting
records to be returned on every poll when there is no timeout.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
