[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106864#comment-17106864
]
Sophie Blee-Goldman commented on KAFKA-9989:
--------------------------------------------
Yeah that looks like the FallbackPriorTaskAssignor to me. Do you see something
like
{code:java}
Failed to fetch end offsets for changelogs, will return previous assignment to
clients and " + "trigger another rebalance to retry.
{code}
in the logs? Depending on when this test was run this specific log message may
or may not have existed, we've made a lot of changes here lately..
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor
> gets assigned task
> ---------------------------------------------------------------------------------------------
>
> Key: KAFKA-9989
> URL: https://issues.apache.org/jira/browse/KAFKA-9989
> Project: Kafka
> Issue Type: Bug
> Components: streams, system tests
> Reporter: Boyang Chen
> Assignee: Boyang Chen
> Priority: Major
>
> System test StreamsUpgradeTest.test_metadata_upgrade could fail due to:
> "Never saw output 'processed [0-9]* records' on ubuntu@worker6"
> which if we take a closer look at, the rebalance happens but has no task
> assignment. We should fix this problem by making the rebalance result as part
> of the check, and skip the record processing validation when the assignment
> is empty.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
