ksqlDB example: creates a new stream with changed number of partitions and a new field as event key (so that its data can be correctly co-partitioned for joining)

copartitioning.sql

CREATE STREAM products ...;

CREATE STREAM products_repartitioned
   WITH (PARTITIONS=42) AS
   SELECT * FROM products
   PARTITION BY product_id
   EMIT CHANGES;