- 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 文件。
...