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)
