2019-07-16 15:36:30,537 TRACE || Retrieving loaded class 'io.debezium.connector.postgresql.PostgresConnector' from 'PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/}' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2019-07-16 15:36:30,537 DEBUG || Getting plugin class loader for connector: 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2019-07-16 15:36:30,589 WARN || The connection password is empty [io.debezium.connector.postgresql.PostgresConnector] 2019-07-16 15:36:30,606 TRACE || Config: {port=----, dbname=products, whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, hostname=----, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:30,607 TRACE || Props: {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:30,607 TRACE || URL: jdbc:postgresql://----:----/products [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:30,870 DEBUG || Connected to jdbc:postgresql://----:----/products with {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:30,954 INFO || Successfully tested connection for jdbc:postgresql://----:----/products with user 'postgres' [io.debezium.connector.postgresql.PostgresConnector] connector.class = io.debezium.connector.postgresql.PostgresConnector connector.class = io.debezium.connector.postgresql.PostgresConnector 2019-07-16 15:36:31,585 INFO || Creating connector pglogical_input of type io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker] 2019-07-16 15:36:31,585 TRACE || Retrieving loaded class 'io.debezium.connector.postgresql.PostgresConnector' from 'PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/}' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2019-07-16 15:36:31,604 INFO || Instantiated connector pglogical_input with version 0.10.0.Beta2 of type class io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker] 2019-07-16 15:36:31,605 DEBUG || Getting plugin class loader for connector: 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2019-07-16 15:36:31,605 DEBUG || WorkerConnector{id=pglogical_input} Initializing connector pglogical_input with config {connector.class=io.debezium.connector.postgresql.PostgresConnector, database.user=postgres, database.dbname=products, slot.name=kafka_streaming, tasks.max=1, database.history.kafka.topic=schema-changes.products, database.server.name=postgres-dev, plugin.name=wal2json_rds_streaming, database.port=----, schema.whitelist=public, table.whitelist=public.fake, tombstones.on.delete=false, database.hostname=----, database.password=----, name=pglogical_input, database.whitelist=products, snapshot.mode=never} [org.apache.kafka.connect.runtime.WorkerConnector] 2019-07-16 15:36:31,627 DEBUG || Getting plugin class loader for connector: 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connector.class = io.debezium.connector.postgresql.PostgresConnector connector.class = io.debezium.connector.postgresql.PostgresConnector 2019-07-16 15:36:31,634 DEBUG || Getting plugin class loader for connector: 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connector.class = io.debezium.connector.postgresql.PostgresConnector connector.class = io.debezium.connector.postgresql.PostgresConnector 2019-07-16 15:36:33,087 DEBUG || Getting plugin class loader for connector: 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] task.class = class io.debezium.connector.postgresql.PostgresConnectorTask 2019-07-16 15:36:33,091 INFO || Instantiated task pglogical_input-0 with version 0.10.0.Beta2 of type io.debezium.connector.postgresql.PostgresConnectorTask [org.apache.kafka.connect.runtime.Worker] 2019-07-16 15:36:33,096 TRACE || Retrieving loaded class 'io.debezium.connector.postgresql.PostgresConnector' from 'PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/}' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2019-07-16 15:36:33,143 INFO || connector.class = io.debezium.connector.postgresql.PostgresConnector [io.debezium.connector.common.BaseSourceTask] 2019-07-16 15:36:33,143 INFO || database.user = postgres [io.debezium.connector.common.BaseSourceTask] 2019-07-16 15:36:33,144 INFO || database.server.name = postgres-dev [io.debezium.connector.common.BaseSourceTask] 2019-07-16 15:36:33,145 INFO || task.class = io.debezium.connector.postgresql.PostgresConnectorTask [io.debezium.connector.common.BaseSourceTask] 2019-07-16 15:36:33,145 INFO || database.hostname = ---- [io.debezium.connector.common.BaseSourceTask] 2019-07-16 15:36:33,146 TRACE || Config: {port=----, dbname=products, whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, hostname=----, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,147 TRACE || Props: {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,147 TRACE || URL: jdbc:postgresql://----:----/products [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,179 DEBUG || Connected to jdbc:postgresql://----:----/products with {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,695 TRACE Postgres|postgres-dev|postgres-connector-task Config: {port=----, dbname=products, whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, hostname=----, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,696 TRACE Postgres|postgres-dev|postgres-connector-task Props: {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,696 TRACE Postgres|postgres-dev|postgres-connector-task URL: jdbc:postgresql://----:----/products [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,714 DEBUG Postgres|postgres-dev|postgres-connector-task Connected to jdbc:postgresql://----:----/products with {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,736 TRACE Postgres|postgres-dev|postgres-connector-task running 'SELECT version(), current_user, current_database()' [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,738 TRACE Postgres|postgres-dev|postgres-connector-task running 'SELECT oid, rolname, rolsuper, rolinherit, rolcreaterole, rolcreatedb, rolcanlogin, rolreplication FROM pg_roles WHERE pg_has_role('postgres', oid, 'member')' [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,745 INFO Postgres|postgres-dev|postgres-connector-task user 'postgres' connected to database 'products' on PostgreSQL 11.1 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.3 20140911 (Red Hat 4.8.3-9), 64-bit with roles: role 'postgres' [superuser: false, replication: false, inherit: true, create role: true, create db: true, can log in: true] [io.debezium.connector.postgresql.PostgresConnectorTask] 2019-07-16 15:36:33,747 TRACE Postgres|postgres-dev|postgres-connector-task Inserting prepared statement 'select * from pg_replication_slots where slot_name = ? and database = ? and plugin = ?' removed from the cache [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,763 DEBUG Postgres|postgres-dev|postgres-connector-task No replication slot 'kafka_streaming' is present for plugin 'wal2json' and database 'products' [io.debezium.connector.postgresql.connection.PostgresConnection] 2019-07-16 15:36:33,764 TRACE Postgres|postgres-dev|postgres-connector-task Closing prepared statement 'select * from pg_replication_slots where slot_name = 'kafka_streaming' and database = 'products' and plugin = 'wal2json'' removed from cache [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,764 INFO Postgres|postgres-dev|postgres-connector-task No previous offset found [io.debezium.connector.postgresql.PostgresConnectorTask] 2019-07-16 15:36:33,764 INFO Postgres|postgres-dev|postgres-connector-task Snapshots are not allowed as per configuration, starting streaming logical changes only [io.debezium.connector.postgresql.snapshot.NeverSnapshotter] 2019-07-16 15:36:33,764 INFO Postgres|postgres-dev|postgres-connector-task Not attempting to take a snapshot, immediately starting to stream logical changes... [io.debezium.connector.postgresql.PostgresConnectorTask] 2019-07-16 15:36:33,767 INFO Postgres|postgres-dev|postgres-connector-task Requested thread factory for connector PostgresConnector, id = postgres-dev named = records-stream-producer [io.debezium.util.Threads] 2019-07-16 15:36:33,773 TRACE Postgres|postgres-dev|postgres-connector-task Config: {port=----, dbname=products, whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, hostname=----, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,773 TRACE Postgres|postgres-dev|postgres-connector-task Props: {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,773 TRACE Postgres|postgres-dev|postgres-connector-task URL: jdbc:postgresql://----:----/products [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,806 DEBUG Postgres|postgres-dev|postgres-connector-task Connected to jdbc:postgresql://----:----/products with {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,832 TRACE Postgres|postgres-dev|postgres-connector-task Inserting prepared statement 'select * from pg_replication_slots where slot_name = ? and database = ? and plugin = ?' removed from the cache [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,835 DEBUG Postgres|postgres-dev|postgres-connector-task No replication slot 'kafka_streaming' is present for plugin 'wal2json' and database 'products' [io.debezium.connector.postgresql.connection.PostgresConnection] 2019-07-16 15:36:33,836 INFO Postgres|postgres-dev|postgres-connector-task Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=null, catalogXmin=null] [io.debezium.connector.postgresql.connection.PostgresConnection] 2019-07-16 15:36:33,836 TRACE Postgres|postgres-dev|postgres-connector-task Closing prepared statement 'select * from pg_replication_slots where slot_name = 'kafka_streaming' and database = 'products' and plugin = 'wal2json'' removed from cache [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,837 DEBUG Postgres|postgres-dev|postgres-connector-task Creating new replication slot 'kafka_streaming' for plugin 'WAL2JSON_RDS_STREAMING' [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] 2019-07-16 15:36:33,837 TRACE Postgres|postgres-dev|postgres-connector-task Config: {port=----, dbname=products, whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, hostname=----, replication=database, assumeMinServerVersion=9.4, preferQueryMode=simple, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,838 TRACE Postgres|postgres-dev|postgres-connector-task Props: {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, replication=database, assumeMinServerVersion=9.4, preferQueryMode=simple, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,838 TRACE Postgres|postgres-dev|postgres-connector-task URL: jdbc:postgresql://----:----/products [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,859 DEBUG Postgres|postgres-dev|postgres-connector-task Connected to jdbc:postgresql://----:----/products with {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, replication=database, assumeMinServerVersion=9.4, preferQueryMode=simple, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,883 DEBUG Postgres|postgres-dev|postgres-connector-task running 'IDENTIFY_SYSTEM' to validate replication connection [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] 2019-07-16 15:36:33,885 DEBUG Postgres|postgres-dev|postgres-connector-task received latest xlogpos '2DA83/E00011A8' [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] 2019-07-16 15:36:33,888 INFO Postgres|postgres-dev|records-stream-producer no previous LSN found in Kafka, streaming from the latest xlogpos or flushed LSN... [io.debezium.connector.postgresql.RecordsStreamProducer] 2019-07-16 15:36:33,889 DEBUG Postgres|postgres-dev|records-stream-producer starting streaming from LSN '2DA83/E00011A8' [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] 2019-07-16 15:36:33,895 TRACE Postgres|postgres-dev|records-stream-producer Class 'org.postgresql.translation.messages' not found. Delegating to parent [org.apache.kafka.connect.runtime.isolation.PluginClassLoader] 2019-07-16 15:36:33,895 TRACE Postgres|postgres-dev|records-stream-producer Class 'org.postgresql.translation.messages_en' not found. Delegating to parent [org.apache.kafka.connect.runtime.isolation.PluginClassLoader] 2019-07-16 15:36:33,896 TRACE Postgres|postgres-dev|records-stream-producer Class 'org.postgresql.translation.messages_en_US' not found. Delegating to parent [org.apache.kafka.connect.runtime.isolation.PluginClassLoader] 2019-07-16 15:36:33,897 DEBUG Postgres|postgres-dev|records-stream-producer Could not register for streaming, retrying without optional options [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] org.postgresql.util.PSQLException: ERROR: parameter "include-unchanged-toast" was deprecated at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2440) at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1116) at org.postgresql.core.v3.QueryExecutorImpl.startCopy(QueryExecutorImpl.java:842) at org.postgresql.core.v3.replication.V3ReplicationProtocol.initializeReplication(V3ReplicationProtocol.java:58) at org.postgresql.core.v3.replication.V3ReplicationProtocol.startLogical(V3ReplicationProtocol.java:42) at org.postgresql.replication.fluent.ReplicationStreamBuilder$1.start(ReplicationStreamBuilder.java:38) at org.postgresql.replication.fluent.logical.LogicalStreamBuilder.start(LogicalStreamBuilder.java:37) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.startPgReplicationStream(PostgresReplicationConnection.java:370) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.createReplicationStream(PostgresReplicationConnection.java:210) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.startStreaming(PostgresReplicationConnection.java:198) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.startStreaming(PostgresReplicationConnection.java:185) at io.debezium.connector.postgresql.RecordsStreamProducer.start(RecordsStreamProducer.java:131) at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:122) 2019-07-16 15:36:33,915 INFO Postgres|postgres-dev|records-stream-producer Requested thread factory for connector PostgresConnector, id = postgres-dev named = records-stream-producer-keep-alive [io.debezium.util.Threads] 2019-07-16 15:36:33,916 INFO Postgres|postgres-dev|records-stream-producer Creating thread debezium-postgresconnector-postgres-dev-records-stream-producer-keep-alive [io.debezium.util.Threads] 2019-07-16 15:36:33,916 TRACE Postgres|postgres-dev|records-stream-producer Config: {port=----, dbname=products, whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, hostname=----, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,917 TRACE Postgres|postgres-dev|records-stream-producer Props: {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,917 TRACE Postgres|postgres-dev|records-stream-producer URL: jdbc:postgresql://----:----/products [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:33,917 TRACE Postgres|postgres-dev|records-stream-producer Forcing status update with replication stream [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] 2019-07-16 15:36:33,938 DEBUG Postgres|postgres-dev|records-stream-producer Connected to jdbc:postgresql://----:----/products with {whitelist=products, server.name=postgres-dev, history.kafka.topic=schema-changes.products, user=postgres, assumeMinServerVersion=9.4, password=----} [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:34,278 TRACE Postgres|postgres-dev|records-stream-producer Inserting prepared statement 'SELECT relreplident FROM pg_catalog.pg_class c LEFT JOIN pg_catalog.pg_namespace n ON c.relnamespace=n.oid WHERE n.nspname=? and c.relname=?' removed from the cache [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:34,280 INFO Postgres|postgres-dev|records-stream-producer REPLICA IDENTITY for 'public.fake' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [io.debezium.connector.postgresql.PostgresSchema] 2019-07-16 15:36:34,281 DEBUG Postgres|postgres-dev|records-stream-producer refreshing DB schema for table 'public.fake' [io.debezium.connector.postgresql.PostgresSchema] 2019-07-16 15:36:34,282 DEBUG Postgres|postgres-dev|records-stream-producer Mapping table 'public.fake' to schemas under 'postgres-dev.public.fake' [io.debezium.relational.TableSchemaBuilder] 2019-07-16 15:36:34,283 WARN Postgres|postgres-dev|records-stream-producer The Kafka Connect schema name 'postgres-dev.public.fake.Value' is not a valid Avro schema name, so replacing with 'postgres_dev.public.fake.Value' [io.debezium.connector.postgresql.PostgresSchema] 2019-07-16 15:36:34,284 WARN Postgres|postgres-dev|records-stream-producer The Kafka Connect schema name 'postgres-dev.public.fake.Key' is not a valid Avro schema name, so replacing with 'postgres_dev.public.fake.Key' [io.debezium.connector.postgresql.PostgresSchema] 2019-07-16 15:36:34,286 DEBUG Postgres|postgres-dev|records-stream-producer - field 'id' (STRING) from column id varchar(2147483647, 0) DEFAULT VALUE NULL [io.debezium.relational.TableSchemaBuilder] 2019-07-16 15:36:34,287 DEBUG Postgres|postgres-dev|records-stream-producer Mapped primary key for table 'public.fake' to schema: null [io.debezium.relational.TableSchemaBuilder] 2019-07-16 15:36:34,287 DEBUG Postgres|postgres-dev|records-stream-producer Mapped columns for table 'public.fake' to schema: {"name" : "postgres_dev.public.fake.Value", "type" : "STRUCT", "optional" : "true", "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "true"}}]} [io.debezium.relational.TableSchemaBuilder] 2019-07-16 15:36:34,288 WARN Postgres|postgres-dev|records-stream-producer The Kafka Connect schema name 'postgres-dev.public.fake.Envelope' is not a valid Avro schema name, so replacing with 'postgres_dev.public.fake.Envelope' [io.debezium.connector.postgresql.PostgresSchema] 2019-07-16 15:36:34,292 TRACE Postgres|postgres-dev|records-stream-producer Closing prepared statement 'SELECT relreplident FROM pg_catalog.pg_class c LEFT JOIN pg_catalog.pg_namespace n ON c.relnamespace=n.oid WHERE n.nspname='public' and c.relname='fake'' removed from cache [io.debezium.jdbc.JdbcConnection] 2019-07-16 15:36:34,293 INFO Postgres|postgres-dev|records-stream-producer Creating thread debezium-postgresconnector-postgres-dev-records-stream-producer [io.debezium.util.Threads] 2019-07-16 15:36:34,294 DEBUG Postgres|postgres-dev|postgres-connector-task polling records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:34,295 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:34,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:34,388 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:34,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:34,888 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:35,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:35,389 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:35,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:35,888 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:36,389 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:36,389 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:36,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:36,888 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:37,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:37,388 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:37,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:37,889 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:38,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:38,388 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:38,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:38,888 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:39,386 TRACE Postgres|postgres-dev|records-stream-producer Chunk arrived from database ] } [io.debezium.connector.postgresql.connection.wal2json.StreamingWal2JsonMessageDecoder] 2019-07-16 15:36:39,386 WARN Postgres|postgres-dev|records-stream-producer Got out of order chunk ] } , recording artifical TX [io.debezium.connector.postgresql.connection.wal2json.StreamingWal2JsonMessageDecoder] 2019-07-16 15:36:39,387 TRACE Postgres|postgres-dev|records-stream-producer Empty change arrived [io.debezium.connector.postgresql.connection.wal2json.StreamingWal2JsonMessageDecoder] 2019-07-16 15:36:39,387 TRACE Postgres|postgres-dev|records-stream-producer Received empty message [io.debezium.connector.postgresql.RecordsStreamProducer] 2019-07-16 15:36:39,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:39,390 DEBUG Postgres|postgres-dev|postgres-connector-task polling records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:39,390 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:39,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:39,889 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:40,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:40,388 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:40,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:40,888 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:41,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:41,388 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:41,889 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:41,889 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:42,388 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:42,388 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:42,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:42,888 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:43,389 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:43,389 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:43,888 DEBUG Postgres|postgres-dev|postgres-connector-task checking for more records... [io.debezium.connector.base.ChangeEventQueue] 2019-07-16 15:36:43,889 DEBUG Postgres|postgres-dev|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue]