在 PostgreSQL 源连接器中，timestamp.column.name 是否支持别名？

编程问答 2022-05-29

问题描述

我正在加入两个表并在 Kafka 中获取数据。如果我将模式用作批量，那么它工作正常，但如果我将模式用作时间戳并相应地给出时间戳.column.name，那么它会显示

enter image description here

我的配置是这样的：

    "name": "join-test-31","config": {
        "connector.class":"io.confluent.connect.jdbc.JdbcSourceConnector","connection.password": "******","validate.non.null": "true","catalog.pattern": "public","connection.url": "jdbc:postgresql://localhost/test","mode": "timestamp","query": "SELECT \"p\".\"Id\" as \"p_Id\",\"p\".\"CreatedDate\" as 
         \"p_CreatedDate\",\"p\".\"ClassId\" as 
         \"p_ClassId\",\"c\".\"Id\" as 
         \"c_Id\",\"c\".\"CreatedDate\" as 
         \"c_CreatedDate\",\"c\".\"ClassId\" as \"c_ClassId\" FROM 
         \"public\".\"Policy\" \"p\" left join \"public\".\"ClassDe\" 
         \"c\" on \"p\".\"DocumentNumber\" = \"c\".\"DocumentNo\"","timestamp.column.name": "p_CreatedDate","key.converter.schemas.enable": "true","topic.prefix": "test_join","connection.user": "postgres","value.converter.schemas.enable": "true","errors.tolerance": "all","value.converter": "org.apache.kafka.connect.json.JsonConverter","errors.log.enable": "true","key.converter":"org.apache.kafka.connect.storage.StringConverter"
    }
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafkacolumn-aliaspostgresqlsqlsql