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

Posted to jira@kafka.apache.org by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2020/11/05 23:27:00 UTC

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

A. Sophie Blee-Goldman created KAFKA-10689:
----------------------------------------------

             Summary: 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
             Fix For: 2.8.0, 2.7.1


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)