For Kafka Streams to performjoins, topics must beco-partitioned, meaning:
They have thesame number of partitions(A), and
They use thesame partitioning strategy(typically by key) (B)
FromKafka Streams Documentation > Joins:
“Co-partitioning is required for Kafka Streams joins. Topics must have the same number of partitions and use the same key-based partitioner.”
Value schema (C) and retention time (D) have no bearing on join compatibility.
[Reference:Kafka Streams Concepts > Joins and Co-Partitioning, ============]
Contribute your Thoughts:
Chosen Answer:
This is a voting comment (?). You can switch to a simple comment. It is better to Upvote an existing comment if you don't have anything to add.
Submit