2019-05-14T20:25:17.976390 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,976] INFO Starting PostgresConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:42) 2019-05-14T20:25:17.977978 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,977] INFO transforms.unwrap.drop.tombstones = false (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.977932 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,977] INFO decimal.handling.mode = double (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.977898 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,977] INFO transforms = unwrap (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.977858 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,977] INFO slot.name = kafka_dw (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.977743 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,977] INFO transforms.unwrap.delete.handling.mode = rewrite (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.977743 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,977] INFO compression.type = snappy (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.977681 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,977] INFO connector.class = io.debezium.connector.postgresql.PostgresConnector (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978874 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO slot.stream.params = add-tables=public.*;filter-tables=public.SequelizeMeta (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978830 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO snapshot.mode = never (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978799 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO transforms.unwrap.operation.header = true (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978759 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO value.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978687 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO name = dummy-name (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978638 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978589 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO database.hostname = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978540 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO task.class = io.debezium.connector.postgresql.PostgresConnectorTask (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978490 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO include.unknown.datatypes = true (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978439 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO key.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978376 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO database.port = 5432 (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978327 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO plugin.name = wal2json (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978277 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO database.server.name = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978228 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO database.user = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978178 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO database.dbname = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978128 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO key.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:17.978077 kafkadw-5 kafka-connect.service [2019-05-14 20:25:17,978] INFO value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:25:18.041226 kafkadw-5 kafka.service [2019-05-14 20:25:18,041] INFO [GroupCoordinator 5]: Preparing to rebalance group connect-dummy-name-s3 in state PreparingRebalance with old generation 33 (__consumer_offsets-40) (reason: Adding new member consumer-7-382862cf-f31f-4755-b954-efaee4376f22) (kafka.coordinator.group.GroupCoordinator) 2019-05-14T20:25:18.077462 kafkadw-5 kafka-connect.service [2019-05-14 20:25:18,077] INFO Cluster ID: KuRA13A2TaWjDbrK9i6YQg (org.apache.kafka.clients.Metadata:365) 2019-05-14T20:25:18.654471 kafkadw-5 kafka-connect.service role '********' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true] (io.debezium.connector.postgresql.PostgresConnectorTask:84) 2019-05-14T20:25:18.654471 kafkadw-5 kafka-connect.service role 'rds_replication' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] 2019-05-14T20:25:18.654471 kafkadw-5 kafka-connect.service [2019-05-14 20:25:18,654] INFO user '********' connected to database '********' on PostgreSQL 9.6.11 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.3 20140911 (Red Hat 4.8.3-9), 64-bit with roles: 2019-05-14T20:25:18.655589 kafkadw-5 kafka-connect.service [2019-05-14 20:25:18,655] INFO Requested thread factory for connector PostgresConnector, id = dummy_name named = records-stream-producer (io.debezium.util.Threads:247) 2019-05-14T20:25:18.655548 kafkadw-5 kafka-connect.service [2019-05-14 20:25:18,655] INFO Previous snapshot has completed successfully, streaming logical changes from last known position (io.debezium.connector.postgresql.PostgresConnectorTask:113) 2019-05-14T20:25:18.655456 kafkadw-5 kafka-connect.service [2019-05-14 20:25:18,655] INFO Found previous offset source_info[server='********'db='********', lsn=398/9119BEC8, txId=25667192, useconds=1557167914608791000, snapshot=false] (io.debezium.connector.postgresql.PostgresConnectorTask:98) 2019-05-14T20:25:18.744794 kafkadw-5 kafka-connect.service [2019-05-14 20:25:18,744] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '********' [during attempt 1 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:20.741815 kafkadw-5 kafka-connect.service [2019-05-14 20:25:20,741] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '********' [during attempt 2 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:21.042330 kafkadw-5 kafka.service [2019-05-14 20:25:21,042] INFO [GroupCoordinator 5]: Stabilized group connect-dummy-name-s3 generation 34 (__consumer_offsets-40) (kafka.coordinator.group.GroupCoordinator) 2019-05-14T20:25:21.044262 kafkadw-5 kafka.service [2019-05-14 20:25:21,044] INFO [GroupCoordinator 5]: Assignment received from leader for group connect-dummy-name-s3 for generation 34 (kafka.coordinator.group.GroupCoordinator) 2019-05-14T20:25:22.744470 kafkadw-5 kafka-connect.service [2019-05-14 20:25:22,744] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 3 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:24.749391 kafkadw-5 kafka-connect.service [2019-05-14 20:25:24,748] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 4 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:26.742118 kafkadw-5 kafka-connect.service [2019-05-14 20:25:26,741] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 5 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:28.741786 kafkadw-5 kafka-connect.service [2019-05-14 20:25:28,741] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 6 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:30.744304 kafkadw-5 kafka-connect.service [2019-05-14 20:25:30,744] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 7 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:32.742511 kafkadw-5 kafka-connect.service [2019-05-14 20:25:32,742] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 8 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:34.741112 kafkadw-5 kafka-connect.service [2019-05-14 20:25:34,740] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 9 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:25:36.742015 kafkadw-5 kafka-connect.service [2019-05-14 20:25:36,741] WARN Cannot obtain valid replication slot 'kafka_dw' for plugin 'wal2json' and database '.'********'' [during attempt 10 out of 900, concurrent tx probably blocks taking snapshot. (io.debezium.connector.postgresql.connection.PostgresConnection:156) 2019-05-14T20:27:38.410279 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,409] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.411203 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,411] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.412609 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,412] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.413590 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,413] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.414665 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,414] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.415535 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,415] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.416293 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,416] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.417775 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,417] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.417042 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,416] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.418528 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,418] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.419716 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,419] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.419123 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,419] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.420277 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,420] INFO REPLICA IDENTITY for 'public.'********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:38.424955 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,424] INFO Creating thread debezium-postgresconnector-.'********'-records-stream-producer (io.debezium.util.Threads:263) 2019-05-14T20:27:38.425654 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,425] INFO WorkerSourceTask{id=dummy-name-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415) 2019-05-14T20:27:38.425567 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,425] INFO WorkerSourceTask{id=dummy-name-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398) 2019-05-14T20:27:38.425223 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,425] INFO WorkerSourceTask{id=dummy-name-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:200) 2019-05-14T20:27:38.426177 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,425] INFO [Producer clientId=producer-5] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1139) 2019-05-14T20:27:38.745719 kafkadw-5 kafka-connect.service [2019-05-14 20:27:38,740] INFO Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLSN=4038371585816] (io.debezium.connector.postgresql.connection.PostgresConnection:153) 2019-05-14T20:27:39.093770 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,093] INFO REPLICA IDENTITY for 'public.******** is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.094674 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,094] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.095915 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,095] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.109105 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,108] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.111086 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,110] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.114228 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,114] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.116022 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,115] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.117439 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,117] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.122442 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,122] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.129405 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,129] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.136006 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,135] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.137357 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,137] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.140785 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,140] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:27:39.151586 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,151] INFO WorkerSourceTask{id=dummy-name-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:200) 2019-05-14T20:27:39.151108 kafkadw-5 kafka-connect.service [2019-05-14 20:27:39,150] INFO Creating thread debezium-postgresconnector-.'********'-records-stream-producer (io.debezium.util.Threads:263) 2019-05-14T20:38:46.706145 kafkadw-5 kafka-connect.service [2019-05-14 20:38:46,706] INFO WorkerSourceTask{id=dummy-name-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415) 2019-05-14T20:38:46.706145 kafkadw-5 kafka-connect.service [2019-05-14 20:38:46,705] INFO WorkerSourceTask{id=dummy-name-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398) 2019-05-14T20:38:47.006691 kafkadw-5 kafka-connect.service [2019-05-14 20:38:47,004] INFO WorkerSourceTask{id=dummy-name-0} Finished commitOffsets successfully in 298 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:497) 2019-05-14T20:38:59.694301 kafkadw-5 kafka-connect.service Terminating due to java.lang.OutOfMemoryError: Java heap space 2019-05-14T20:39:06.175817 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,175] INFO Starting PostgresConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:42) 2019-05-14T20:39:06.175817 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,175] INFO transforms = unwrap (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.175817 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,175] INFO slot.name = kafka_dw (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.175817 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,175] INFO transforms.unwrap.delete.handling.mode = rewrite (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.175817 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,175] INFO compression.type = snappy (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.175817 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,175] INFO connector.class = io.debezium.connector.postgresql.PostgresConnector (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176863 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO name = dummy-name (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176740 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176740 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO database.hostname = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176740 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO task.class = io.debezium.connector.postgresql.PostgresConnectorTask (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176626 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO include.unknown.datatypes = true (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176626 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO key.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176626 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO database.port = 5432 (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176626 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO plugin.name = wal2json (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO database.server.name = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO database.user = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO database.dbname = ******** (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO key.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO transforms.unwrap.type = io.debezium.transforms.UnwrapFromEnvelope (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO transforms.unwrap.drop.tombstones = false (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.176360 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,175] INFO decimal.handling.mode = double (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.177186 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,177] INFO slot.stream.params = add-tables=public.*;filter-tables=public.SequelizeMeta (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.177186 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,177] INFO snapshot.mode = never (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.177100 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,177] INFO transforms.unwrap.operation.header = true (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.177100 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,176] INFO value.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:44) 2019-05-14T20:39:06.856921 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,856] INFO Requested thread factory for connector PostgresConnector, id = dummy_name named = records-stream-producer (io.debezium.util.Threads:247) 2019-05-14T20:39:06.856921 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,856] INFO Previous snapshot has completed successfully, streaming logical changes from last known position (io.debezium.connector.postgresql.PostgresConnectorTask:113) 2019-05-14T20:39:06.856921 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,856] INFO Found previous offset source_info[server='********'db='********', lsn=3AC/D19BFB20, txId=25995877, useconds=1557866301366920000, snapshot=false] (io.debezium.connector.postgresql.PostgresConnectorTask:98) 2019-05-14T20:39:06.856921 kafkadw-6 kafka-connect.service role '********' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true] (io.debezium.connector.postgresql.PostgresConnectorTask:84) 2019-05-14T20:39:06.856921 kafkadw-6 kafka-connect.service role 'rds_replication' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] 2019-05-14T20:39:06.856921 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,855] INFO user '********' connected to database '********' on PostgreSQL 9.6.11 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.3 20140911 (Red Hat 4.8.3-9), 64-bit with roles: 2019-05-14T20:39:06.900821 kafkadw-6 kafka-connect.service [2019-05-14 20:39:06,900] INFO Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLSN=4040785918752] (io.debezium.connector.postgresql.connection.PostgresConnection:153) 2019-05-14T20:39:07.220600 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,220] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.222200 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,222] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.223811 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,223] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.225378 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,225] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.226980 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,226] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.228407 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,228] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.229951 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,229] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.231454 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,231] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.232909 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,232] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.234308 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,234] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.235719 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,235] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.237231 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,236] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.238548 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,238] INFO REPLICA IDENTITY for 'public.********' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema:105) 2019-05-14T20:39:07.243873 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,243] INFO WorkerSourceTask{id=dummy-name-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:200) 2019-05-14T20:39:07.243599 kafkadw-6 kafka-connect.service [2019-05-14 20:39:07,243] INFO Creating thread debezium-postgresconnector-dummy_name-records-stream-producer (io.debezium.util.Threads:263) 2019-05-14T20:39:33.168376 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,168] INFO Stopping task dummy-name-0 (org.apache.kafka.connect.runtime.Worker:588) 2019-05-14T20:39:33.168376 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,168] INFO Stopping connector dummy-name (org.apache.kafka.connect.runtime.Worker:328) 2019-05-14T20:39:33.168214 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,168] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238) 2019-05-14T20:39:33.168072 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,167] INFO [Worker clientId=connect-1, groupId=connect] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:871) 2019-05-14T20:39:33.169706 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,169] INFO Stopped connector dummy-name (org.apache.kafka.connect.runtime.Worker:344) 2019-05-14T20:39:33.179893 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,175] WARN Closing replication stream due to db connection IO exception... (io.debezium.connector.postgresql.RecordsStreamProducer:138) 2019-05-14T20:39:33.431715 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,431] INFO WorkerSourceTask{id=dummy-name-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415) 2019-05-14T20:39:33.431715 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,431] INFO WorkerSourceTask{id=dummy-name-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,432] INFO [Producer clientId=producer-5] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1139) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,432] ERROR WorkerSourceTask{id=dummy-name-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:178) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service ... 12 more 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1035) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1079) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.PGStream.receiveChar(PGStream.java:306) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.VisibleBufferedInputStream.read(VisibleBufferedInputStream.java:67) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:109) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.VisibleBufferedInputStream.readMore(VisibleBufferedInputStream.java:140) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at sun.security.ssl.AppInputStream.read(AppInputStream.java:105) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at sun.security.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:933) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:975) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at sun.security.ssl.InputRecord.read(InputRecord.java:503) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at sun.security.ssl.InputRecord.readFully(InputRecord.java:465) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at java.net.SocketInputStream.read(SocketInputStream.java:141) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at java.net.SocketInputStream.read(SocketInputStream.java:204) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service Caused by: java.net.SocketException: Socket closed 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service ... 5 more 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at io.debezium.connector.postgresql.RecordsStreamProducer.lambda$start$0(RecordsStreamProducer.java:119) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at io.debezium.connector.postgresql.RecordsStreamProducer.streamChanges(RecordsStreamProducer.java:133) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.read(PostgresReplicationConnection.java:249) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.v3.replication.V3PGReplicationStream.read(V3PGReplicationStream.java:70) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:124) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:155) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:41) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1037) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service Caused by: org.postgresql.util.PSQLException: Database connection failed when reading from copy 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at java.lang.Thread.run(Thread.java:748) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at java.util.concurrent.FutureTask.run(FutureTask.java:266) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:221) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:245) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at io.debezium.connector.postgresql.PostgresConnectorTask.poll(PostgresConnectorTask.java:156) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:170) 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service org.apache.kafka.connect.errors.ConnectException: An exception ocurred in the change event producer. This connector will be stopped. 2019-05-14T20:39:33.435107 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,431] ERROR WorkerSourceTask{id=dummy-name-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:177) 2019-05-14T20:39:33.441807 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,441] INFO [Worker clientId=connect-1, groupId=connect] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) 2019-05-14T20:39:33.441807 kafkadw-6 kafka-connect.service [2019-05-14 20:39:33,441] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268)