- Status: Design
- Author: Jiyong Huang
- Discussion: https://github.com/lf-edge/ekuiper/issues/1467
当前 eKuiper 支持在 Create Stream 的时候指定数据结构类型等。然而该方式有几个问题：
...
添加更多解码类型，如 custom (自定义），delemited，avro
每种解码类型均支持静态方式。用户需实现编解码接口，并编译为 go 插件 so，提前通过 schema registry 注册。
Serilization Format | Schema Keys | Parse Schema Descriptor |
|---|---|---|
json | optional | json schema (TBD) |
binary | n/a | n/a |
protobuf | required | |
custom | required, provided by the extended code | optional, provided by the extended code |
delimited (TBD) | n/a, must have stream schema def or the first line should have def | n/a |
avro (TBD) | required | avro |
Schema Registry
添加功能，允许注册静态 schema。即添加可选的 soFile 属性，用于指定静态解析代码。若存在 soFile，则使用插件系统载入 so 文件，进行解析；否则动态解析 proto 文件。
...