kafka-connect org.apache.avro.SchemaParseException: 非法字符$

Question

我使用jdbc源连接器，当我想连接一个名称中带有"$"的表时，得到以下错误。

org.apache.avro.SchemaParseException: Illegal character <<tablename>>$

我试着用utf-8转义，比如tablename\u0024，还是同样的错误。

如何处理这些特殊的字符？

Answer 1

看起来模式验证对从你的表名创建的模式名不满意。 你可以用 SetSchemaMetadata在文档中有这样一个例子。

"transforms": "SetSchemaMetadata",
"transforms.SetSchemaMetadata.type": "org.apache.kafka.connect.transforms.SetSchemaMetadata$Value",
"transforms.SetSchemaMetadata.schema.name": "avro"

这将为值信息字段设置模式名称。