Как объединить неравное количество потоков, содержащих разделы в KSQL, помимо увеличения раздела?
Пример Поток-1 имеет 3 раздела, а поток-2 - 2 раздела. В этом случае, конечно, мы можем увеличить количество разделов для Stream-1 при объединении 3. Но я хочу знать, есть ли другой способ объединить неравно-секционированные потоки через KSQL?
Нет, к сожалению, KStream / KSQL не поддерживает объединение для неравно разделенных тем.
Обязательным условием является то, что обе темы должны иметь одинаковое количество разделов перед вызовом операции соединения, в противном случае она не удастся.
Подробнее о требовании совместного разделения можно прочитать здесь: https://docs.confluent.io/current/ksql/docs/developer-guide/partition-data.html#partition-data-to-enable-присоединяетсяк
Чтобы обеспечить совместное разделение, вы можете использовать предложение PARTITION_BY для создания нового потока:
CREATE STREAM topic_rekeyed WITH (PARTITIONS=6) AS SELECT * FROM topic PARTITION BY topic_key;
