[
https://issues.apache.org/jira/browse/KAFKA-12268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-12268.
------------------------------------
Resolution: Fixed
> 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: John Roesler
> Priority: Critical
> 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)
