Source

append和upsert kafka

StreamSQL

Metric

源码
DeserializationSchema
KafkaDeserializationSchema
区别