[
https://issues.apache.org/jira/browse/KAFKA-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-10689:
----------------------------------------------
Assignee: A. Sophie Blee-Goldman
> 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: Major
> 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)
