[KAFKA-6443] KTable involved in multiple joins could result in duplicate results

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Assignee: Unassigned
• Reporter: Guozhang Wang
• Created: 11/Jan/18 19:12
• Updated: 28/Mar/20 07:51

Description

Consider the following multi table-table joins:

table1.join(table2).join(table2);    // "join" could be replaced with "leftJoin" and "outerJoin"

where table2 is involved multiple times in this multi-way joins. In this case, when a new record from the source topic of table2 is being processing, it will send to two children down in the topology and hence may resulting in duplicated join results depending on the join types.

Issue Links

• mentioned in: Page Loading...