org.apache.pulsar.kafka.shade.avro.SchemaParseException

用pulsar的connector提取mysql表数据时worker不断重启,日志如下:
ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable - Encountered exception in source read
org.apache.pulsar.kafka.shade.avro.SchemaParseException: Illegal initial character: 1v1

查看了库表数据,表结构中的字段名是1v1,会报上述错误。
请帮忙尽快看下这个问题,还请给出解决方案,目前我这边只是忽略了这个表,但这个表很重要需要加上。

Avro格式的中field名字必须:

  • 以[A-Za-z_]开头
  • 接下来的名字中只能包含[A-Za-z0-9_]
    1v1 是个不合法的field名字,需要修改。