You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
<p>For equi-joins, input data must be co-partitioned when joining. This ensures that input records with the same key from both sides of the
1700
1700
join, are delivered to the same stream task during processing.
1701
1701
<strong>It is your responsibility to ensure data co-partitioning when joining</strong>.
1702
-
Co-partitioning is not required when performing <aclass="reference internal"href="#streams-developer-guide-dsl-joins-ktable-ktable-fk-join"><spanclass="std std-ref">KTable-KTable Foreign-Key joins</span></a> and <aclass="reference internal"href="#streams_concepts_globalktable"><spanclass="std std-ref">Global KTable joins</span></a>.
1702
+
Co-partitioning is not required when performing <aclass="reference internal"href="#ktable-ktable-fk-join"><spanclass="std std-ref">KTable-KTable Foreign-Key joins</span></a> and <aclass="reference internal"href="#streams_concepts_globalktable"><spanclass="std std-ref">Global KTable joins</span></a>.
1703
1703
</p>
1704
1704
<p>The requirements for data co-partitioning are:</p>
not required because <em>all</em> partitions of the <codeclass="docutils literal"><spanclass="pre">GlobalKTable</span></code>‘s underlying changelog stream are made available to
1725
1725
each <codeclass="docutils literal"><spanclass="pre">KafkaStreams</span></code> instance. That is, each instance has a full copy of the changelog stream. Further, a
1726
1726
<codeclass="docutils literal"><spanclass="pre">KeyValueMapper</span></code> allows for non-key based joins from the <codeclass="docutils literal"><spanclass="pre">KStream</span></code> to the <codeclass="docutils literal"><spanclass="pre">GlobalKTable</span></code>.
1727
-
<aclass="reference internal"href="#streams-developer-guide-dsl-joins-ktable-ktable-fk-join"><spanclass="std std-ref">KTable-KTable Foreign-Key joins</span></a> also do not require co-partitioning. Kafka Streams internally ensures co-partitioning for Foreign-Key joins.
1727
+
<aclass="reference internal"href="#ktable-ktable-fk-join"><spanclass="std std-ref">KTable-KTable Foreign-Key joins</span></a> also do not require co-partitioning. Kafka Streams internally ensures co-partitioning for Foreign-Key joins.
0 commit comments