我正在尝试使用查询以批量模式使用io.confluent.connect.jdbc.jdbcsourceconnector。
query = select name, cast(ID as NUMBER(20,2)),status from table_name这可能吗？如果可能的话，我是不是遗漏了什么？我要走了
exception (org.apache.kafka.connect.runtime.WorkerTask:148)
org.apache.avro.SchemaParseException: Illegal character in: CAST(IDASNUMBER(20,2))
1条答案
按热度按时间zzwlnbp81#
第二列使用别名。此别名必须是目标avro字段的名称。