折腾ksql

前提，基于这个项目的dbsinks kafka connector

1. 创建stream

   create stream stream_name with (kafka_topic='topic', value_format='avro');
   

2. SET 'auto.offset.reset' = 'earliest';
   

3. run select

   select after->"ID"  from  stream_name limit 1;