Kafka JDBC 커넥터에 연결

2017-11-17 22 views 0 likes

io.confluent.connect.jdbc.JdbcSourceConnector를 쿼리를 사용하여 대량 모드로 사용하려고합니다.Kafka JDBC 커넥터에 연결

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))

답변

두 번째 열에 별칭을 사용하십시오. 이 별칭은 대상 avro-field의 이름이어야합니다.

2017-11-19 19:45:03 TobiSH