Table of Contents

1. Challenge

   Create a Stream to Pull Data in from the Topic

   1. Start a KSQL session:

      sudo ksql
      

   2. Set auto.offset.reset to earliest:

      SET 'auto.offset.reset' = 'earliest';
      

   3. Look at the data in the member_signups topic:

      PRINT 'member_signups' FROM BEGINNING;
      

   4. Create a stream from the topic:

      CREATE STREAM member_signups
        (firstname VARCHAR,
          lastname VARCHAR,
          email_notifications BOOLEAN)
        WITH (KAFKA_TOPIC='member_signups',
          VALUE_FORMAT='DELIMITED');
      

2. Challenge

   Create a Persistent Streaming Query to Write Data to the Output Topic in Real Time

   1. Create the persistent streaming query:

      CREATE STREAM member_signups_email AS
        SELECT * FROM member_signups WHERE email_notifications=true;
      

   2. View the data in the output topic to verify that everything is working:

      PRINT 'MEMBER_SIGNUPS_EMAIL' FROM BEGINNING;