[jira] [Updated] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

["Jason Gustafson (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jason Gustafson updated KAFKA-5097:
-----------------------------------
    Priority: Blocker  (was: Critical)

> KafkaConsumer.poll throws IllegalStateException
> -----------------------------------------------
>
>                 Key: KAFKA-5097
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5097
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Ismael Juma
>            Assignee: Eno Thereska
>            Priority: Blocker
>             Fix For: 0.10.2.1
>
>
> The backport of KAFKA-5075 to 0.10.2 seems to have introduced a regression: If a fetch returns more data than `max.poll.records` and there is a rebalance or the user changes the assignment/subscription after a `poll` that doesn't return all the fetched data, the next call will throw an `IllegalStateException`. More discussion in the following PR that includes a fix:
> https://github.com/apache/kafka/pull/2876/files#r112413428
> This issue caused a Streams system test to fail, see KAFKA-4755.
> We should fix the regression before releasing 0.10.2.1.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)