Kafka JDBC разъем приемника не корректно конвертировать метку времени - PullRequest
Новая
       17

Kafka JDBC разъем приемника не корректно конвертировать метку времени

0 голосов
/ 03 мая 2018

у меня есть схема 

  {
      "type" : "record",
      "name" : "test",
      "namespace" : "test",
      "fields" : [ {
        "name" : "time",
        "type": [ "null", {
          "type": "long",
          "logicalType": "timestamp-millis"
        }]
      }, 
....
 {
        "name" : "time2",
        "type": ["null", {
          "type" :  "long",
          "logicaltype": "timestamp-millis"
        }]
      }
    }

Но когда коннектор kafka десериализует данные и создает вставку SQL, у меня появляется следующая ошибка 

column "time2" is of type timestamp without time zone but expression is of type bigint

Вставка: 

INSERT INTO "test" ("time",  "time2")
VALUES  ('2018-2-2 20:14:45.507000 +0:0:0', 1517602485507)

это странно, потому что дата и код совпадают. Почему первое поле даты "время" конвертируется нормально, а во втором у меня проблема?

...