[
https://issues.apache.org/jira/browse/KAFKA-21170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-21170:
------------------------------------
Labels: (was: group-coordinator streams)
> Validate Streams task assignor output before accepting target assignments
> -------------------------------------------------------------------------
>
> Key: KAFKA-21170
> URL: https://issues.apache.org/jira/browse/KAFKA-21170
> Project: Kafka
> Issue Type: Bug
> Components: group-coordinator, streams
> Reporter: sanghyeok An
> Assignee: sanghyeok An
> Priority: Minor
>
> Streams groups support broker-side custom task assignors. A custom
> implementation
> may return an invalid assignment, but the coordinator currently does not
> validate several assignment invariants before accepting the result.
> No issue has been identified in the built-in sticky assignor. This proposal
> adds validation to detect invalid output from faulty custom assignors and
> provide a clear error before that output becomes the group's target
> assignment.
> For example:
> # Member A currently owns task T as active.
> # A custom assignor returns T as active for both A and member B.
> # The coordinator accepts both target assignments.
> # A retains T because it remains in its target assignment.
> # B waits for A to release T.
> While A retains ownership and the conflicting target remains unchanged, B
> cannot
> complete reconciliation. The coordinator does not report the invalid assignor
> output as the cause.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
