Re: joins & co-location

2021-02-25 Thread Bill Bejeck
Hi Nicolae In KStream-KStream, KStream-KTable, and KTable-KTable joins, both sides of the join need to have the same number of partitions. Kafka Streams will check for this, and if the number of partitions isn’t the same, Kafka Streams will throw a TopologyException. Foreign key joins don’t requi

joins & co-location

2021-02-25 Thread Dumitru Nicolae Marasoiu
Hi guys, in case of KTable with KTable joins, is co-location a requirement? Do the 2 topics need to have the same number of partitions? https://forum.confluent.io/t/ktable-ktable-joins-is-colocation-needed/1034 Thank you, Nicolae