You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2021/03/22 17:11:00 UTC

[jira] [Resolved] (KAFKA-12268) System tests broken because consumer returns early without records

     [ 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)