ableegoldman opened a new pull request #11591: URL: https://github.com/apache/kafka/pull/11591
Fix for one of the causes of failure in the NamedTopologyIntegrationTest: `org.apache.kafka.streams.errors.StreamsException: java.lang.IllegalStateException: Must initialize prevActiveTasks from ownedPartitions before initializing remaining tasks.` This exception could occur if a member sent in a subscription where all of its `ownedPartitions` were from a named topology that is no longer recognized by the group leader, eg because it was just removed from the client. We should filter each ClientState based on the current topology only so the assignor only processes the partitions/tasks it can identify. The member with the out-of-date tasks will eventually clean them up when the `#removeNamedTopology` API is invoked on them -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
