Kafka 连接 JDBC 连接器答案

【问题标题】：Kafka connect JDBC connectorKafka 连接 JDBC 连接器
【发布时间】：2018-05-01 13:13:10
【问题描述】：

我正在尝试使用查询以批量模式使用 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】：

为第二列使用别名。此别名必须是目标 avro-field 的名称。

【讨论】：