Add user merged stream

V000003__Add_user_merged_stream.sql

CREATE STREAM IF NOT EXISTS user_merged_stream WITH (
    KAFKA_TOPIC = '{{ cookiecutter.user_merged_topic }}',
    VALUE_FORMAT = 'JSON'
  )
  AS
  SELECT
    REPLACE(`user_id`, '"', '') as KEY,
    AS_VALUE(REPLACE(`user_id`, '"', '')) as `user_id`,
    `first_name` STRING,
    `last_name` STRING,
    `app_id` STRING
   FROM user_OUT_STREAM 
   PARTITION BY REPLACE(`user_id`, '"', '');
   SET 'auto.offset.reset' = 'earliest';
   
INSERT INTO user_merge_stream
WITH (query_id='USER_IN_INTO_USER_MERGED')
  SELECT 
    `user_id` as KEY,
    AS_VALUE(`user_id`) as `user_id`,
    `first_name` STRING,
    `last_name` STRING,
    `app_id` STRING
  FROM  USER_IN_STREAM
  PARTITION BY `user_id`;
  SET 'auto.offset.reset' = 'earliest';