Loading...

XML

Word

Printable

Details

Type: Bug
Resolution: Done
Priority: Major
Fix Version/s: 0.7.2
Affects Version/s: 0.7.1
Component/s: postgresql-connector
Labels:
None

Steps to Reproduce:

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')

SFDC Cases Counter:
SFDC Cases Links:

Description

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