Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Save VictorHugoBatista/b245f2395e6c5f3625cab24d126f00ec to your computer and use it in GitHub Desktop.
Save VictorHugoBatista/b245f2395e6c5f3625cab24d126f00ec to your computer and use it in GitHub Desktop.
#Criar Stream
CREATE STREAM f_test_stream (message VARCHAR) WITH (kafka_topic='test', value_format='json');
#Criar o Stream que consome de outro Stream
CREATE STREAM test_consumer_all_stream WITH (KAFKA_TOPIC='test1', value_format='json') AS SELECT * FROM f_test_stream;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment