Skip to content

Instantly share code, notes, and snippets.

@IL-ADAM

IL-ADAM/V000002__Add_user_outbound_stream.sql

Last active September 19, 2023 13:07
Show Gist options
  • Save IL-ADAM/0ed355d8eee64d41fe21c503600d9b2d to your computer and use it in GitHub Desktop.
Save IL-ADAM/0ed355d8eee64d41fe21c503600d9b2d to your computer and use it in GitHub Desktop.
Download ZIP
Add user outbound stream
Raw
V000002__Add_user_outbound_stream.sql
CREATE STREAM IF NOT EXISTS user_outbound_stream(
`user_id` STRING KEY,
`first_name` STRING,
`last_name` STRING,
`app_id` STRING,
) WITH (
KAFKA_TOPIC = '{{ cookiecutter.user_outbound_topic }}',
VALUE_FORMAT = 'JSON_SR'
);
SET 'auto.offset.reset' = 'earliest';
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment