Skip to content

Instantly share code, notes, and snippets.

@ram-pi

ram-pi/json-to-avro.sql

Forked from miguno/json-to-avro.sql
Created August 17, 2022 14:48
Show Gist options
  • Save ram-pi/ab083e1f33109590092b55ff434d68d2 to your computer and use it in GitHub Desktop.
Save ram-pi/ab083e1f33109590092b55ff434d68d2 to your computer and use it in GitHub Desktop.
Download ZIP
Using KSQL to convert a Kafka topic from JSON to Avro format.
Raw
json-to-avro.sql
CREATE STREAM sensor_events_json (sensor_id VARCHAR, temperature INTEGER, ...)
WITH (KAFKA_TOPIC='events-topic', VALUE_FORMAT='JSON');
CREATE STREAM sensor_events_avro WITH (VALUE_FORMAT='AVRO') AS SELECT * FROM sensor_events_json;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment