Andy Bryant created KAFKA-7671:
----------------------------------
Summary: A KStream/GlobalKTable join shouldn't reset the
repartition flag
Key: KAFKA-7671
URL: https://issues.apache.org/jira/browse/KAFKA-7671
Project: Kafka
Issue Type: Improvement
Components: streams
Affects Versions: 2.0.1
Reporter: Andy Bryant
Currently a KStream/GlobalKTable join resets the repartition required flag to
false.
I have a topology where I map a stream, join with a GlobalKTable, then
groupByKey then aggregate.
The aggregate wasn't behaving correctly because it didn't force a repartition
as I expected. The KStream/GlobalKTable join had reset the flag and hence I was
getting the same keys in different partitions.
Since a KStream/GlobalKTable join does not itself force a repartition, it
should simply propagate the flag down to the resultant KStream the same way
most other operators work.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
