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)