我估计你是用的 confluent schema registry 的 avro。 可以使用下在 master 分支提供的 avro-confluent format [1]。 需要自己 build 下源码。
Best, Jark [1]: https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/formats/avro-confluent.html On Wed, 11 Nov 2020 at 14:20, 奔跑的小飞袁 <s_hongli...@126.com> wrote: > 这是我尝试输出的message长度 > message length is: 529 > message length is: 212 > message length is: 391 > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
