Skip to content

Instantly share code, notes, and snippets.

@apurvam
Last active April 28, 2018 17:54
Show Gist options
  • Save apurvam/bec524b52413caf2201c427754c8277a to your computer and use it in GitHub Desktop.
Save apurvam/bec524b52413caf2201c427754c8277a to your computer and use it in GitHub Desktop.
Example of specify TIMESTAMP_FORMAT in KSQL
CREATE STREAM foo (col1 varchar, col2 varchar, timecol varchar) \
WITH (kafka_topic=’foo_topic’, TIMESTAMP=’timecol’, \
TIMESTAMP_FORMAT=’yyyy-MM-ddTHH:mm:SSZ’, value_format=’json’);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment