[
https://issues.apache.org/jira/browse/KAFKA-19857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Quah updated KAFKA-19857:
------------------------------
Description:
We call iterator.remove() without a preceding iterator.next() when there are
running tasks and remove() is defined to throw an IllegalStateException if the
next method has not yet been called.
This causes unclean unloads of group coordinator partitions when there is a
running regex resolution for example.
was:This causes unclean unloads of group coordinator partitions when there is
a running regex resolution for example.
> CoordinatorExecutorImpl.cancelAll always throws IllegalStateException when
> there are running tasks
> --------------------------------------------------------------------------------------------------
>
> Key: KAFKA-19857
> URL: https://issues.apache.org/jira/browse/KAFKA-19857
> Project: Kafka
> Issue Type: Bug
> Components: group-coordinator
> Reporter: Sean Quah
> Assignee: Sean Quah
> Priority: Major
>
> We call iterator.remove() without a preceding iterator.next() when there are
> running tasks and remove() is defined to throw an IllegalStateException if
> the next method has not yet been called.
> This causes unclean unloads of group coordinator partitions when there is a
> running regex resolution for example.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
