Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-525

DateTimeFormatter Exception in wal2json

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 0.7.2
    • 0.7.1
    • postgresql-connector
    • None
    • Hide

      1. start a postgres connector using wal2json plugin
      2. update/insert a column having timestamp with microseconds(eg. '2017-12-01 11:07:43.595')

      Show
      1. start a postgres connector using wal2json plugin 2. update/insert a column having timestamp with microseconds(eg. '2017-12-01 11:07:43.595')

      postgres data type - timestamp without time zone

      Caused by: org.apache.kafka.connect.errors.ConnectException: java.time.format.DateTimeParseException: Text '2017-12-05 06:32:16.461' could not be parsed, unparsed text found at index 19
      at io.debezium.connector.postgresql.connection.wal2json.DateTimeFormat$ISODateTimeFormat.format(DateTimeFormat.java:114)
      at io.debezium.connector.postgresql.connection.wal2json.DateTimeFormat$ISODateTimeFormat.timestamp(DateTimeFormat.java:74)
      at io.debezium.connector.postgresql.connection.wal2json.Wal2JsonReplicationMessage.getValue(Wal2JsonReplicationMessage.java:229)
      at io.debezium.connector.postgresql.connection.wal2json.Wal2JsonReplicationMessage$1.getValue(Wal2JsonReplicationMessage.java:129)
      at io.debezium.connector.postgresql.RecordsStreamProducer.lambda$columnValues$3(RecordsStreamProducer.java:413)
      at java.util.ArrayList.forEach(ArrayList.java:1255)
      at io.debezium.connector.postgresql.RecordsStreamProducer.columnValues(RecordsStreamProducer.java:408)
      at io.debezium.connector.postgresql.RecordsStreamProducer.process(RecordsStreamProducer.java:244)
      at io.debezium.connector.postgresql.RecordsStreamProducer.lambda$streamChanges$2(RecordsStreamProducer.java:119)
      at io.debezium.connector.postgresql.connection.wal2json.Wal2JsonMessageDecoder.processMessage(Wal2JsonMessageDecoder.java:54)
      at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.deserializeMessages(PostgresReplicationConnection.java:199)
      at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.read(PostgresReplicationConnection.java:184)
      at io.debezium.connector.postgresql.RecordsStreamProducer.streamChanges(RecordsStreamProducer.java:119)
      at io.debezium.connector.postgresql.RecordsStreamProducer.lambda$start$1(RecordsStreamProducer.java:105)
      ... 5 more

              jpechane Jiri Pechanec
              khushalvirmani Khushal Virmani (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: