[jira] [Assigned] (KAFKA-20885) Incorrect IQ metadata in "streams" protocol

["Matthias J. Sax (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias J. Sax reassigned KAFKA-20885:
---------------------------------------

    Assignee: Matthias J. Sax

> Incorrect IQ metadata in "streams" protocol
> -------------------------------------------
>
>                 Key: KAFKA-20885
>                 URL: https://issues.apache.org/jira/browse/KAFKA-20885
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 4.1.0
>            Reporter: Matthias J. Sax
>            Assignee: Matthias J. Sax
>            Priority: Major
>
> Note, I am setting 4.1.0 as affected version, because this code shipped with 4.1.0, even if "streams" protocol is only an "early access" in 4.1.0.
> IQ metadata reports non-existent partitions when a member owns a non-prefix task set of a subtopology with uneven source-topic partition counts: There is a Task T with two input topic A (5 partitions) and B (2 partitions). A member has tasks 0_1 and 0_3 assigned. For topic B, it should only report to host task 0_1 (because 0_3 has no B partition assigned), but it incorrectly reports to host both 0_1 and 0_3.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)