kafka jdbc源代码不显示数值

8fsztsew  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(215)

我正在部署kafka connect jdbc源代码。它正正确地连接到数据库,但我得到的结果是:

{
  "schema": {
    "type": "struct",
    "fields": [
      {
        "type": "bytes",
        "optional": false,
        "name": "org.apache.kafka.connect.data.Decimal",
        "version": 1,
        "parameters": {
          "scale": "0"
        },
        "field": "ID"
      },
      {
        "type": "bytes",
        "optional": false,
        "name": "org.apache.kafka.connect.data.Decimal",
        "version": 1,
        "parameters": {
          "scale": "0"
        },
        "field": "TENANT_ID"
      },
      {
        "type": "bytes",
        "optional": false,
        "name": "org.apache.kafka.connect.data.Decimal",
        "version": 1,
        "parameters": {
          "scale": "0"
        },
        "field": "IS_ACTIVE"
      },
      {
        "type": "int64",
        "optional": false,
        "name": "org.apache.kafka.connect.data.Timestamp",
        "version": 1,
        "field": "CREATION_DATE"
      },
      {
        "type": "int64",
        "optional": true,
        "name": "org.apache.kafka.connect.data.Timestamp",
        "version": 1,
        "field": "LAST_LOGIN"
      },
      {
        "type": "string",
        "optional": true,
        "field": "NAME"
      },
      {
        "type": "string",
        "optional": true,
        "field": "MOBILEPHONE"
      },
      {
        "type": "string",
        "optional": true,
        "field": "EMAIL"
      },
      {
        "type": "string",
        "optional": true,
        "field": "USERNAME"
      },
      {
        "type": "string",
        "optional": true,
        "field": "PASSWORD"
      },
      {
        "type": "string",
        "optional": true,
        "field": "EXTERNAL_ID"
      }
    ],
    "optional": false
  },
  "payload": {
    "ID": "fdo=",
    "TENANT_ID": "Uw==",
    "IS_ACTIVE": "AQ==",
    "CREATION_DATE": 1548987456000,
    "LAST_LOGIN": 1557401837030,
    "NAME": " ",
    "MOBILEPHONE": " ",
    "EMAIL": " ",
    "USERNAME": "ES00613751",
    "PASSWORD": " ",
    "EXTERNAL_ID": " "
  }
}

如您所见,数值和时间戳值没有正确显示值。
配置:

name=jdbc-teradata-source-connector
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=...
numeric.maping=best_fit
topic.prefix=test-2
mode=timestamp+incrementing
timestamp.column.name=LAST_LOGIN
incrementing.column.name=ID

topic=test-jdbc-oracle-source

数值Map不起作用,因为它是合流的3.2.2我也试图将数字转换为数值,但它也不起作用。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题