ksqlDB example: Create a new stream with the desired number of partitions.

increased-partitions.sql

CREATE STREAM products ...;

CREATE STREAM products_repartitioned
   WITH (PARTITIONS=30) AS
   SELECT * FROM products
   EMIT CHANGES;