Skip to content

Instantly share code, notes, and snippets.

@rmoff
rmoff / Continuous Conversion of Kafka topics from JSON to Avro with KSQL.adoc
Last active August 18, 2023 21:11
Continuous Conversion of Kafka topics from JSON to Avro with KSQL

@rmoff / 04 Apr 2018

This is easy with KSQL :)

Here’s a dummy topic, in JSON:

$ kafka-console-consumer --bootstrap-server localhost:9092 --from-beginning --topic mysql_users
{"uid":1,"name":"Cliff","locale":"en_US","address_city":"St Louis","elite":"P"}