IT博客汇
  • 首页
  • 精华
  • 技术
  • 设计
  • 资讯
  • 扯淡
  • 权利声明
  • 登录 注册

    Flink 集成 Debezium Confluent Avro 报 AvroTypeException: Found <topic>.Value, expecting union 错误解决方法

    bluishglc发表于 2024-01-30 13:39:20
    love 0
    在使用 Flink 读取 Debezium Confluent Avro 格式的 CDC 数据时,遇到了上述错误。背景介绍和具体操作请参考 《Flink 集成 Debezium Confluent Avro ( format=debezium-avro-confluent )》 一文,该错误是在查询 Kafka Sink Table 时(也就是真正读取并解析 Avro CDC 数据时)发生的,错误信息 AvroTypeException: Found .Value, expecting union


沪ICP备19023445号-2号
友情链接