Источник JDBC Kafka не показывает числовые значения - PullRequest
Новая
       12

Источник JDBC Kafka не показывает числовые значения

0 голосов
/ 09 мая 2019

Я развертываю источник JDBC Kafka Connect.Он правильно соединяется с базой данных, но я получаю следующий результат: 

{
  "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": " "
  }
}

Как видите, числовые значения и метки времени не показывают значение должным образом.

config: 

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

Числовое сопоставление не работает, поскольку оно является Confluent 3.2.2 Я также пытался преобразовать числа в числовые, но оно также не работает.

...