Directions
1. Define the source topic’s schema:
CREATE STREAM source_avro \ WITH (KAFKA_TOPIC='mysql_users_avro', VALUE_FORMAT='AVRO');
2. Create a derived topic in delimited (CSV) format:
CREATE STREAM target_delim WITH (KAFKA_TOPIC='mysql_users_delim',VALUE_FORMAT='DELIMITED') AS \ SELECT * FROM source_avro;
$ kafkacat -C -b localhost:9092 -t mysql_users_delim 1,Cliff,en_US,St Louis,P