You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Tomaz Muraus (Jira)" <ji...@apache.org> on 2022/01/25 11:35:00 UTC

[jira] [Commented] (KAFKA-13406) Cooperative sticky assignor got stuck due to assignment validation failed

    [ https://issues.apache.org/jira/browse/KAFKA-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481754#comment-17481754 ] 

Tomaz Muraus commented on KAFKA-13406:
--------------------------------------

First thank you for fixing this bug.

 

I see that v3.1.0 which includes this bug fix has just been released.

 

The fix version field seems to indicate this bug fix will aksi be included in the v2.8.x release series. Do we happen to have an eta for v2.8.2 (we are also affected by this bug, but we still run 2.8.x series so we can't use v3.1.0 just yet).

 

Thanks!

> Cooperative sticky assignor got stuck due to assignment validation failed
> -------------------------------------------------------------------------
>
>                 Key: KAFKA-13406
>                 URL: https://issues.apache.org/jira/browse/KAFKA-13406
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients
>    Affects Versions: 3.0.0
>            Reporter: Luke Chen
>            Assignee: Luke Chen
>            Priority: Major
>             Fix For: 3.1.0, 3.0.1, 2.8.2
>
>
> We'll do validateCooperativeAssignment for cooperative assignor, where we validate if there are previously owned partitions directly transfer to other consumers without "revoke" step. However, the "ownedPartition" in subscription might contain out-of-dated data, which might cause the validation always failure.
> We should consider the short-term fix it by disabling validateCooperationAssignment for built-in cooperativeStickyAssignor because we've already consider the generation in the assignor, and discard the old generation ownedPartition if any.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)