Hands On: Splitting Two Streams with ksqlDB

Hands On: Splitting Two Streams with ksqlDB

This exercise will demonstrate how to split streams in ksqlDB.

Inspect Your Existing Data

1. Begin by looking at the orders_combined stream from the module 9 exercise, which has orders from both the US and the UK:

   SELECT * FROM orders_combined EMIT CHANGES;

   Click Run query and see that the results contain orders from both the US and the UK.

Create New Split Streams

2. Create a new stream to contain only orders from the US:

   CREATE STREAM us_orders AS
   SELECT * FROM orders_combined
   WHERE source = 'US';

   Click Run query.

3. Create another new stream to contain only orders from the UK:

   CREATE STREAM uk_orders AS
   SELECT * FROM orders_combined
   WHERE source = 'UK';

   Click Run query.

Inspect Your Data Using the Flow Tab

4. Move to the Flow tab. Click on the US_ORDERS stream. On the right-hand side, you see that the stream contains only orders from the US. Click on the UK_ORDERS stream and you see that it likewise contains only orders from the UK.