Description
There are valid reasons to want to join a stream to itself, but Kafka Streams does not currently support this (Invalid topology: Topic foo has already been registered by another source.). To perform the join requires creating a second stream as a clone of the first, and then doing a join between the two. This is a clunky workaround and results in unnecessary duplication of data.
Attachments
Issue Links
- Is contained by
-
KAFKA-14209 Optimize stream stream self join to use single state store
-
- Resolved
-