[
https://issues.apache.org/jira/browse/KAFKA-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978766#comment-15978766
]
ASF GitHub Bot commented on KAFKA-5097:
---------------------------------------
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/2887
KAFKA-5097: Add testFetchAfterPartitionWithFetchedRecordsIsUnassigned
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka kafka-5097-unit-test
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2887.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2887
----
commit 29c9eb8f4ab0dccdfeafb67bc7aef5ce25891bba
Author: Ismael Juma <[email protected]>
Date: 2017-04-21T13:54:29Z
KAFKA-5097: Add testFetchAfterPartitionWithFetchedRecordsIsUnassigned
----
> 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)
