create stream test_s1 ( “after” struct< “up” varchar, “u” varchar, “num” varchar >, “op” varchar ) with (kafka_topic=’test_raw_v1′, VALUE_AVRO_SCHEMA_FULL_NAME=’com.xyz.IdEvent’, value_format=’AVRO’); Hello Everyone, I created stream “test_s1” using above query, which is backed by an existing topic “test_raw_v1”. This Topic has schema registered in the schema registry under namespace “com.xyz.IdEvent” with AVRO value format. This Topic […]