You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2021/02/02 18:07:00 UTC

[jira] [Updated] (KAFKA-10689) Assignor can't determine number of partitions on FJK with upstream windowed repartition

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

Matthias J. Sax updated KAFKA-10689:
------------------------------------
    Fix Version/s: 2.6.2

> Assignor can't determine number of partitions on FJK with upstream windowed repartition
> ---------------------------------------------------------------------------------------
>
>                 Key: KAFKA-10689
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10689
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 2.5.0
>            Reporter: A. Sophie Blee-Goldman
>            Assignee: A. Sophie Blee-Goldman
>            Priority: Critical
>             Fix For: 2.8.0, 2.7.1, 2.6.2
>
>
> Due to a minor logical gap in how windowed repartition sink nodes are written to the topology, they are never added to the official map of sink topics tracked by the InternalTopologyBuilder. This makes it impossible to determine the number of partitions of downstream repartition topics in StreamsPartitionAssignor#setRepartitionTopicMetadataNumberOfPartitions, causing the assignor to loop infinitely in this method. 
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)