我估计你是用的 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, 奔跑的小飞袁 wrote:
> 这是我尝试输出的message长度
>
这是我尝试输出的message长度
message length is: 529
message length is: 212
message length is: 391
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Hi，可以试下输出下message的长度么？
--
发件人：奔跑的小飞袁
发送时间：2020年11月11日(星期三) 11:40
收件人：user-zh
主 题：flink1.11 读取kafka avro格式数据发序列化失败
hello 我在使用flink1.11版本读取kafka
avro格式数据时遇到了错误，由于我们的avro特殊，因此源码稍微作了修改，以下是改动的代码片段
@Override
public T
