2018-05-07 08:47:57,889 INFO || Kafka Connect distributed worker initializing ... [org.apache.kafka.connect.cli.ConnectDistributed] 2018-05-07 08:47:57,895 INFO || WorkerInfo values: jvm.args = -Xmx2500m, -Xms2500m, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Djava.rmi.server.hostname=0.0.0.0, -Dcom.sun.management.jmxremote.rmi.port=9010, -Dcom.sun.management.jmxremote.port=9010, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/kafka/bin/../logs, -Dlog4j.configuration=file:/kafka/config/log4j.properties jvm.spec = Oracle Corporation, OpenJDK 64-Bit Server VM, 1.8.0_161, 25.161-b14 jvm.classpath = :/kafka/bin/../libs/aopalliance-repackaged-2.5.0-b32.jar:/kafka/bin/../libs/argparse4j-0.7.0.jar:/kafka/bin/../libs/avro-1.8.2.jar:/kafka/bin/../libs/common-config-4.0.0.jar:/kafka/bin/../libs/common-utils-4.0.0.jar:/kafka/bin/../libs/commons-lang3-3.5.jar:/kafka/bin/../libs/connect-api-1.0.0.jar:/kafka/bin/../libs/connect-file-1.0.0.jar:/kafka/bin/../libs/connect-json-1.0.0.jar:/kafka/bin/../libs/connect-runtime-1.0.0.jar:/kafka/bin/../libs/connect-transforms-1.0.0.jar:/kafka/bin/../libs/guava-20.0.jar:/kafka/bin/../libs/hk2-api-2.5.0-b32.jar:/kafka/bin/../libs/hk2-locator-2.5.0-b32.jar:/kafka/bin/../libs/hk2-utils-2.5.0-b32.jar:/kafka/bin/../libs/jackson-annotations-2.9.1.jar:/kafka/bin/../libs/jackson-core-2.9.1.jar:/kafka/bin/../libs/jackson-core-asl-1.9.13.jar:/kafka/bin/../libs/jackson-databind-2.9.1.jar:/kafka/bin/../libs/jackson-jaxrs-base-2.9.1.jar:/kafka/bin/../libs/jackson-jaxrs-json-provider-2.9.1.jar:/kafka/bin/../libs/jackson-mapper-asl-1.9.13.jar:/kafka/bin/../libs/jackson-module-jaxb-annotations-2.9.1.jar:/kafka/bin/../libs/javassist-3.20.0-GA.jar:/kafka/bin/../libs/javassist-3.21.0-GA.jar:/kafka/bin/../libs/javax.annotation-api-1.2.jar:/kafka/bin/../libs/javax.inject-1.jar:/kafka/bin/../libs/javax.inject-2.5.0-b32.jar:/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/kafka/bin/../libs/javax.ws.rs-api-2.0.1.jar:/kafka/bin/../libs/jersey-client-2.25.1.jar:/kafka/bin/../libs/jersey-common-2.25.1.jar:/kafka/bin/../libs/jersey-container-servlet-2.25.1.jar:/kafka/bin/../libs/jersey-container-servlet-core-2.25.1.jar:/kafka/bin/../libs/jersey-guava-2.25.1.jar:/kafka/bin/../libs/jersey-media-jaxb-2.25.1.jar:/kafka/bin/../libs/jersey-server-2.25.1.jar:/kafka/bin/../libs/jetty-continuation-9.2.22.v20170606.jar:/kafka/bin/../libs/jetty-http-9.2.22.v20170606.jar:/kafka/bin/../libs/jetty-io-9.2.22.v20170606.jar:/kafka/bin/../libs/jetty-security-9.2.22.v20170606.jar:/kafka/bin/../libs/jetty-server-9.2.22.v20170606.jar:/kafka/bin/../libs/jetty-servlet-9.2.22.v20170606.jar:/kafka/bin/../libs/jetty-servlets-9.2.22.v20170606.jar:/kafka/bin/../libs/jetty-util-9.2.22.v20170606.jar:/kafka/bin/../libs/jopt-simple-5.0.4.jar:/kafka/bin/../libs/kafka-avro-serializer-4.0.0.jar:/kafka/bin/../libs/kafka-clients-1.0.0.jar:/kafka/bin/../libs/kafka-connect-avro-converter-4.0.0.jar:/kafka/bin/../libs/kafka-log4j-appender-1.0.0.jar:/kafka/bin/../libs/kafka-schema-registry-client-4.0.0.jar:/kafka/bin/../libs/kafka-streams-1.0.0.jar:/kafka/bin/../libs/kafka-streams-examples-1.0.0.jar:/kafka/bin/../libs/kafka-tools-1.0.0.jar:/kafka/bin/../libs/kafka_2.11-1.0.0.jar:/kafka/bin/../libs/log4j-1.2.17.jar:/kafka/bin/../libs/lz4-java-1.4.jar:/kafka/bin/../libs/maven-artifact-3.5.0.jar:/kafka/bin/../libs/metrics-core-2.2.0.jar:/kafka/bin/../libs/osgi-resource-locator-1.0.1.jar:/kafka/bin/../libs/plexus-utils-3.0.24.jar:/kafka/bin/../libs/reflections-0.9.11.jar:/kafka/bin/../libs/rocksdbjni-5.7.3.jar:/kafka/bin/../libs/scala-library-2.11.11.jar:/kafka/bin/../libs/slf4j-api-1.7.25.jar:/kafka/bin/../libs/slf4j-log4j12-1.7.25.jar:/kafka/bin/../libs/snappy-java-1.1.4.jar:/kafka/bin/../libs/validation-api-1.1.0.Final.jar:/kafka/bin/../libs/zkclient-0.10.jar:/kafka/bin/../libs/zookeeper-3.4.10.jar os.spec = Linux, amd64, 4.4.0-98-generic os.vcpus = 16 [org.apache.kafka.connect.runtime.WorkerInfo] 2018-05-07 08:47:57,896 INFO || Scanning for plugin classes. This might take a moment ... [org.apache.kafka.connect.cli.ConnectDistributed] 2018-05-07 08:47:57,957 INFO || Loading plugin from: /kafka/connect/pipedrive-partition-SMT-0.1.jar [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,159 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/pipedrive-partition-SMT-0.1.jar} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,159 INFO || Added plugin 'com.pipedrive.PartitionByField' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,159 INFO || Added plugin 'com.pipedrive.PartitionByDatabase' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,162 INFO || Loading plugin from: /kafka/connect/telmate-timestamp-convert-SMT.jar [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,172 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/telmate-timestamp-convert-SMT.jar} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,172 INFO || Added plugin 'org.telmate.SMT.DebeziumTimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,172 INFO || Added plugin 'org.telmate.SMT.DebeziumTimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:58,172 INFO || Loading plugin from: /kafka/connect/debezium-connector-mysql [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:59,357 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:59,358 INFO || Added plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:59,358 INFO || Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:59,358 INFO || Added plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:47:59,370 INFO || Loading plugin from: /kafka/connect/debezium-connector-postgres [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:00,065 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:00,065 INFO || Added plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:00,074 INFO || Loading plugin from: /kafka/connect/debezium-connector-mongodb [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:00,959 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:00,959 INFO || Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:00,960 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,785 INFO || Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,785 INFO || Added plugin 'org.apache.kafka.connect.tools.MockConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,785 INFO || Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,785 INFO || Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,785 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,786 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,787 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,788 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,788 INFO || Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,788 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,788 INFO || Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,788 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,788 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,789 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,789 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,789 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,789 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,789 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,789 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,790 INFO || Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,791 INFO || Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,791 INFO || Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,791 INFO || Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,791 INFO || Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,791 INFO || Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,792 INFO || Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,792 INFO || Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,792 INFO || Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,792 INFO || Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,792 INFO || Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,793 INFO || Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,793 INFO || Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,793 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,793 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,794 INFO || Added alias 'PartitionByDatabase' to plugin 'com.pipedrive.PartitionByDatabase' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,852 INFO || Added alias 'PartitionByField' to plugin 'com.pipedrive.PartitionByField' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,852 INFO || Added alias 'UnwrapFromMongoDbEnvelope' to plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,852 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,852 INFO || Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,853 INFO || Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,853 INFO || Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,854 INFO || Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2018-05-07 08:48:06,872 INFO || DistributedConfig values: access.control.allow.methods = access.control.allow.origin = bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] client.id = config.storage.replication.factor = 1 config.storage.topic = debezium-configs-company-db connections.max.idle.ms = 540000 group.id = debezium-group-company-db heartbeat.interval.ms = 3000 internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class org.apache.kafka.connect.json.JsonConverter metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 60000 offset.flush.timeout.ms = 5000 offset.storage.partitions = 25 offset.storage.replication.factor = 1 offset.storage.topic = debezium-offsets-company-db plugin.path = [/kafka/connect] rebalance.timeout.ms = 60000 receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 40000 rest.advertised.host.name = selfIP rest.advertised.port = 14067 rest.host.name = 172.17.0.40 rest.port = 8083 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS status.storage.partitions = 5 status.storage.replication.factor = 1 status.storage.topic = debezium-status-company-db task.shutdown.graceful.timeout.ms = 10000 value.converter = class org.apache.kafka.connect.json.JsonConverter worker.sync.timeout.ms = 3000 worker.unsync.backoff.ms = 300000 [org.apache.kafka.connect.runtime.distributed.DistributedConfig] 2018-05-07 08:48:07,018 INFO || Logging initialized @9852ms [org.eclipse.jetty.util.log] 2018-05-07 08:48:07,374 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:07,375 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:07,657 INFO || Successfully logged in. [org.apache.kafka.common.security.authenticator.AbstractLogin] 2018-05-07 08:48:07,758 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:07,758 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:07,761 INFO || Kafka Connect distributed worker initialization took 9871ms [org.apache.kafka.connect.cli.ConnectDistributed] 2018-05-07 08:48:07,761 INFO || Kafka Connect starting [org.apache.kafka.connect.runtime.Connect] 2018-05-07 08:48:07,761 INFO || Starting REST server [org.apache.kafka.connect.runtime.rest.RestServer] 2018-05-07 08:48:07,761 INFO || Herder starting [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:48:07,761 INFO || Worker starting [org.apache.kafka.connect.runtime.Worker] 2018-05-07 08:48:07,762 INFO || Starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2018-05-07 08:48:07,762 INFO || Starting KafkaBasedLog with topic debezium-offsets-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:07,765 INFO || AdminClientConfig values: bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,859 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,859 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,859 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,860 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,861 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:07,861 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:07,861 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:08,053 INFO || jetty-9.2.22.v20170606 [org.eclipse.jetty.server.Server] 2018-05-07 08:48:09,367 INFO || ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 enable.idempotence = false interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,562 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,562 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,562 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,562 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,562 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,562 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,651 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,651 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,652 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,652 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,659 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,660 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,660 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,660 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,660 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,661 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,662 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,662 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,662 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,665 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,666 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,666 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,666 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,667 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,667 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,667 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,668 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,668 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,668 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:09,668 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:09,669 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:09,677 INFO || ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] check.crcs = true client.id = connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = debezium-group-company-db heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,857 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,857 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,857 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,858 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:09,859 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:09,859 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:10,660 INFO || [Consumer clientId=consumer-1, groupId=debezium-group-company-db] Discovered coordinator kafkaIP1:9092 (kafkaIP2 rack: kafkaIP3.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:48:10,763 INFO || Started o.e.j.s.ServletContextHandler@dfa1f68{/,null,AVAILABLE} [org.eclipse.jetty.server.handler.ContextHandler] 2018-05-07 08:48:10,769 INFO || Finished reading KafkaBasedLog for topic debezium-offsets-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:10,769 INFO || Started KafkaBasedLog for topic debezium-offsets-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:10,769 INFO || Finished reading offsets topic and starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2018-05-07 08:48:10,770 INFO || Worker started [org.apache.kafka.connect.runtime.Worker] 2018-05-07 08:48:10,770 INFO || Starting KafkaBasedLog with topic debezium-status-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:10,771 INFO || AdminClientConfig values: bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,772 INFO || Started ServerConnector@c5b55c8{HTTP/1.1}{172.17.0.40:8083} [org.eclipse.jetty.server.ServerConnector] 2018-05-07 08:48:10,772 INFO || Started @13607ms [org.eclipse.jetty.server.Server] 2018-05-07 08:48:10,772 INFO || REST server listening at http://172.17.0.40:8083/, advertising URL http://selfIP:14067/ [org.apache.kafka.connect.runtime.rest.RestServer] 2018-05-07 08:48:10,772 INFO || Kafka Connect started [org.apache.kafka.connect.runtime.Connect] 2018-05-07 08:48:10,773 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,774 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,850 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,850 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:10,851 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:10,851 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:10,986 INFO || ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 enable.idempotence = false interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,989 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:10,990 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:10,990 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:10,992 INFO || ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] check.crcs = true client.id = connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = debezium-group-company-db heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:10,995 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:10,995 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:11,242 INFO || [Consumer clientId=consumer-2, groupId=debezium-group-company-db] Discovered coordinator kafkaIP1:9092 (kafkaIP2 rack: kafkaIP3.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:48:11,317 INFO || Finished reading KafkaBasedLog for topic debezium-status-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:11,317 INFO || Started KafkaBasedLog for topic debezium-status-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:11,318 INFO || Starting KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2018-05-07 08:48:11,318 INFO || Starting KafkaBasedLog with topic debezium-configs-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:11,318 INFO || AdminClientConfig values: bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:48:11,320 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:11,320 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:11,480 INFO || ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 enable.idempotence = false interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,482 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:48:11,483 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:11,483 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:11,483 INFO || ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] check.crcs = true client.id = connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = debezium-group-company-db heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'consumer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,485 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'producer.security.protocol' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2018-05-07 08:48:11,486 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:11,486 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:48:11,700 INFO || [Consumer clientId=consumer-3, groupId=debezium-group-company-db] Discovered coordinator kafkaIP1:9092 (kafkaIP2 rack: kafkaIP3.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:48:11,728 INFO || Removed connector company_db_1020 due to null configuration. This is usually intentional and does not indicate an issue. [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2018-05-07 08:48:11,729 INFO || Removed connector company_db_1019 due to null configuration. This is usually intentional and does not indicate an issue. [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2018-05-07 08:48:11,730 INFO || Removed connector company_db_1019 due to null configuration. This is usually intentional and does not indicate an issue. [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2018-05-07 08:48:11,730 INFO || Removed connector company_db_1020 due to null configuration. This is usually intentional and does not indicate an issue. [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2018-05-07 08:48:11,730 INFO || Finished reading KafkaBasedLog for topic debezium-configs-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:11,730 INFO || Started KafkaBasedLog for topic debezium-configs-company-db [org.apache.kafka.connect.util.KafkaBasedLog] 2018-05-07 08:48:11,730 INFO || Started KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2018-05-07 08:48:11,730 INFO || Herder started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:48:11,783 INFO || [Worker clientId=connect-1, groupId=debezium-group-company-db] Discovered coordinator kafkaIP1:9092 (kafkaIP2 rack: kafkaIP3.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:48:11,786 INFO || [Worker clientId=connect-1, groupId=debezium-group-company-db] (Re-)joining group [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:48:13,948 INFO || [Worker clientId=connect-1, groupId=debezium-group-company-db] Successfully joined group with generation 23 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:48:13,949 INFO || Joined group and got assignment: Assignment{error=0, leader='connect-1-938fbf7c-beb4-4b54-8b4e-786c971c9eb7', leaderUrl='http://leaderIP:24840/', offset=16, connectorIds=[], taskIds=[]} [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:48:13,950 WARN || Catching up to assignment's config offset. [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:48:13,950 INFO || Current config state offset -1 is behind group assignment 16, reading to end of config log [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:48:14,233 INFO || Finished reading to end of log and updated config snapshot, new config log offset: 16 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:48:14,233 INFO || Starting connectors and tasks using config offset 16 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:48:14,233 INFO || Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:30,288 INFO || 172.17.0.40 - - [07/May/2018:08:49:30 +0000] "GET /connectors/company_db_1019 HTTP/1.1" 404 66 201 [org.apache.kafka.connect.runtime.rest.RestServer] 2018-05-07 08:49:40,452 INFO || Connector company_db_1019 config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:40,453 INFO || Rebalance started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:40,453 INFO || Finished stopping tasks in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:40,453 INFO || [Worker clientId=connect-1, groupId=debezium-group-company-db] (Re-)joining group [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:49:40,960 INFO || [Worker clientId=connect-1, groupId=debezium-group-company-db] Successfully joined group with generation 24 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] 2018-05-07 08:49:40,961 INFO || Joined group and got assignment: Assignment{error=0, leader='connect-1-938fbf7c-beb4-4b54-8b4e-786c971c9eb7', leaderUrl='http://leaderIP:24840/', offset=17, connectorIds=[], taskIds=[company_db_1019-0]} [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:40,962 INFO || Starting connectors and tasks using config offset 17 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:40,963 INFO || Starting task company_db_1019-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:40,963 INFO || Creating task company_db_1019-0 [org.apache.kafka.connect.runtime.Worker] 2018-05-07 08:49:40,966 INFO || ConnectorConfig values: connector.class = io.debezium.connector.mysql.MySqlConnector key.converter = null name = company_db_1019 tasks.max = 1 transforms = [route] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig] 2018-05-07 08:49:41,167 INFO || EnrichedConnectorConfig values: connector.class = io.debezium.connector.mysql.MySqlConnector key.converter = null name = company_db_1019 tasks.max = 1 transforms = [route] transforms.route.key.field.regex = ([^.]+)\.company_([0-9]+)\.([^.]+) transforms.route.key.field.replacement = $2 transforms.route.topic.regex = ([^.]+)\.([^.]+)\.([^.]+) transforms.route.topic.replacement = company_db.$3 transforms.route.type = class io.debezium.transforms.ByLogicalTableRouter value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2018-05-07 08:49:41,173 INFO || TaskConfig values: task.class = class io.debezium.connector.mysql.MySqlConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2018-05-07 08:49:41,173 INFO || Instantiated task company_db_1019-0 with version 0.7.5 of type io.debezium.connector.mysql.MySqlConnectorTask [org.apache.kafka.connect.runtime.Worker] 2018-05-07 08:49:41,261 INFO || ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 enable.idempotence = false interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 2147483647 retries = 2147483647 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:49:41,265 INFO || Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:49:41,265 INFO || Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:49:41,277 INFO || Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2018-05-07 08:49:41,501 INFO || Starting MySqlConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || connector.class = io.debezium.connector.mysql.MySqlConnector [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || snapshot.locking.mode = none [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || transforms.route.key.field.name = company_id [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || tasks.max = 1 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.consumer.sasl.jaas.config = org.apache.kafka.common.security.scram.ScramLoginModule required username="debezium" password="****"; [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.kafka.topic = debezium-history-company-db-1019 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.kafka.security.protocol = SASL_PLAINTEXT [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || transforms = route [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.consumer.security.protocol = SASL_PLAINTEXT [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.kafka.recovery.attempts = 1000 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || include.schema.changes = false [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || table.whitelist = company_[0-9]+\.(activity|activity_types|data_extra|deal_custom_fields_ref|deal_products|deal_stage_log|deals|files|mail_message_parties|mail_messages|mail_parties|mail_threads|notes|org|org_custom_fields_ref|people|people_custom_fields_ref|product_custom_fields_ref|product_variations|products|stages) [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || tombstones.on.delete = false [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || transforms.route.type = io.debezium.transforms.ByLogicalTableRouter [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || transforms.route.topic.regex = ([^.]+)\.([^.]+)\.([^.]+) [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || transforms.PartitionByDatabase.partitions = 3 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.kafka.recovery.poll.interval.ms = 10000 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || poll.interval.ms = 1000 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.kafka.sasl.mechanism = SCRAM-SHA-256 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.kafka.consumer.max.poll.records = 1000 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || transforms.route.topic.replacement = company_db.$3 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.whitelist = company_[0-9]+ [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.producer.sasl.mechanism = SCRAM-SHA-256 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.producer.sasl.jaas.config = org.apache.kafka.common.security.scram.ScramLoginModule required username="debezium" password="****"; [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.user = debezium [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.kafka.sasl.jaas.config = org.apache.kafka.common.security.scram.ScramLoginModule required username="debezium" password="****"; [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,552 INFO || database.history.producer.acks = all [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.server.id = 101900 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.history.producer.security.protocol = SASL_PLAINTEXT [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || transforms.route.key.field.regex = ([^.]+)\.company_([0-9]+)\.([^.]+) [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.history.kafka.bootstrap.servers = kafkaIP1:9092,kafkaIP2:9092,kafkaIP3 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.server.name = company_db_1019 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.port = 3306 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || inconsistent.schema.handling.mode = fail [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || transforms.route.key.field.replacement = $2 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || task.class = io.debezium.connector.mysql.MySqlConnectorTask [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.hostname = mysqlIP [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.password = **** [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || transforms.PartitionByDatabase.type = com.pipedrive.PartitionByDatabase [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || name = company_db_1019 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.history.store.only.monitored.tables.ddl = true [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || database.history.consumer.sasl.mechanism = SCRAM-SHA-256 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || snapshot.mode = schema_only [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:41,553 INFO || connect.timeout.ms = 120000 [io.debezium.connector.common.BaseSourceTask] 2018-05-07 08:49:42,377 INFO || KafkaDatabaseHistory Consumer config: {security.protocol=SASL_PLAINTEXT, enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=company_db_1019-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=kafkaIP1:9092,kafkaIP2:9092,kafkaIP3, sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="debezium" password="****";, client.id=company_db_1019-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, sasl.mechanism=SCRAM-SHA-256, fetch.min.bytes=1} [io.debezium.relational.history.KafkaDatabaseHistory] 2018-05-07 08:49:42,378 INFO || KafkaDatabaseHistory Producer config: {security.protocol=SASL_PLAINTEXT, bootstrap.servers=kafkaIP1:9092,kafkaIP2:9092,kafkaIP3, value.serializer=org.apache.kafka.common.serialization.StringSerializer, sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="debezium" password="****";, buffer.memory=1048576, retries=1, linger.ms=0, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=company_db_1019-dbhistory, sasl.mechanism=SCRAM-SHA-256, batch.size=32768, max.block.ms=10000, acks=all} [io.debezium.relational.history.KafkaDatabaseHistory] 2018-05-07 08:49:42,384 INFO MySQL|company_db_1019|task ProducerConfig values: acks = all batch.size = 32768 bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] buffer.memory = 1048576 client.id = company_db_1019-dbhistory compression.type = none connections.max.idle.ms = 540000 enable.idempotence = false interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 10000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 1 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.StringSerializer [org.apache.kafka.clients.producer.ProducerConfig] 2018-05-07 08:49:42,454 INFO MySQL|company_db_1019|task Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:49:42,454 INFO MySQL|company_db_1019|task Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:49:42,666 INFO MySQL|company_db_1019|task AdminClientConfig values: bootstrap.servers = [kafkaIP1:9092, kafkaIP2:9092, kafkaIP3:9092] client.id = company_db_1019-dbhistory connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 1 retry.backoff.ms = 100 sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = SCRAM-SHA-256 security.protocol = SASL_PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,667 WARN MySQL|company_db_1019|task The configuration 'batch.size' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,667 WARN MySQL|company_db_1019|task The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,667 WARN MySQL|company_db_1019|task The configuration 'buffer.memory' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,667 WARN MySQL|company_db_1019|task The configuration 'key.serializer' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,668 WARN MySQL|company_db_1019|task The configuration 'value.serializer' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,668 WARN MySQL|company_db_1019|task The configuration 'max.block.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,668 WARN MySQL|company_db_1019|task The configuration 'linger.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2018-05-07 08:49:42,668 INFO MySQL|company_db_1019|task Kafka version : 1.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:49:42,668 INFO MySQL|company_db_1019|task Kafka commitId : aaa7af6d4a11b29d [org.apache.kafka.common.utils.AppInfoParser] 2018-05-07 08:49:42,886 INFO MySQL|company_db_1019|task Database history topic '(name=debezium-history-company-db-1019, numPartitions=1, replicationFactor=3, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created [io.debezium.relational.history.KafkaDatabaseHistory] 2018-05-07 08:49:42,886 INFO MySQL|company_db_1019|task Found no existing offset, so preparing to perform a snapshot [io.debezium.connector.mysql.MySqlConnectorTask] 2018-05-07 08:49:42,920 INFO MySQL|company_db_1019|task Requested thread factory for connector MySqlConnector, id = company_db_1019 named = binlog-client [io.debezium.util.Threads] 2018-05-07 08:49:42,939 INFO MySQL|company_db_1019|task Requested thread factory for connector MySqlConnector, id = company_db_1019 named = snapshot [io.debezium.util.Threads] 2018-05-07 08:49:42,940 INFO MySQL|company_db_1019|task Creating thread debezium-mysqlconnector-company_db_1019-snapshot [io.debezium.util.Threads] 2018-05-07 08:49:42,941 INFO || WorkerSourceTask{id=company_db_1019-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:49:42,941 INFO MySQL|company_db_1019|snapshot Starting snapshot for jdbc:mysql://mysqlIP:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=convertToNull with user 'debezium' with locking mode 'none' [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,943 INFO MySQL|company_db_1019|snapshot Snapshot is using user 'debezium' with these MySQL grants: [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,944 INFO MySQL|company_db_1019|snapshot GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'debezium'@'10.235.%.%' [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,944 INFO MySQL|company_db_1019|snapshot MySQL server variables related to change data capture: [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_cache_size = 2097152 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_checksum = CRC32 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_direct_non_transactional_updates = OFF [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_error_action = ABORT_SERVER [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_format = ROW [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_group_commit_sync_delay = 0 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_group_commit_sync_no_delay_count = 0 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_gtid_simple_recovery = ON [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_max_flush_queue_time = 0 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_order_commits = ON [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_row_image = FULL [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,951 INFO MySQL|company_db_1019|snapshot binlog_rows_query_log_events = OFF [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot binlog_stmt_cache_size = 2097152 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_set_client = utf8 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_set_connection = utf8 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_set_database = utf8 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_set_filesystem = binary [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_set_results = utf8 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_set_server = utf8 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_set_system = utf8 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot character_sets_dir = /usr/share/mysql/charsets/ [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot collation_connection = utf8_general_ci [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot collation_database = utf8_general_ci [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot collation_server = utf8_general_ci [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot enforce_gtid_consistency = ON [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot gtid_executed_compression_period = 1000 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot gtid_mode = ON [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot gtid_next = AUTOMATIC [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot gtid_owned = [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot gtid_purged = 36e81c0e-42d6-11e8-9953-fa163e31dda3:1-54153, 4ca60776-d4fd-11e7-b7bd-fa163e5997e8:1-20106, 6163e17a-efe4-11e7-bb8e-fa163e31dda3:1-29265177, be401594-f975-11e7-9367-fa163e5997e8:1-28333698 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,952 INFO MySQL|company_db_1019|snapshot have_backup_safe_binlog_info = YES [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot innodb_api_enable_binlog = OFF [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot innodb_locks_unsafe_for_binlog = OFF [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot innodb_version = 5.7.19-17 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot log_statements_unsafe_for_binlog = ON [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot max_binlog_cache_size = 1073741824 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot max_binlog_files = 0 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot max_binlog_size = 1073741824 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot max_binlog_stmt_cache_size = 1073741824 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot protocol_version = 10 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot session_track_gtids = OFF [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot slave_type_conversions = [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot sync_binlog = 1 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot system_time_zone = UTC [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot time_zone = SYSTEM [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot tls_version = TLSv1,TLSv1.1,TLSv1.2 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot tx_isolation = REPEATABLE-READ [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot tx_read_only = OFF [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot version = 5.7.19-17-log [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot version_comment = Percona Server (GPL), Release '17', Revision 'e19a6b7b73f' [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot version_compile_machine = x86_64 [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot version_compile_os = debian-linux-gnu [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,953 INFO MySQL|company_db_1019|snapshot Step 0: disabling autocommit and enabling repeatable read transactions [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,959 INFO MySQL|company_db_1019|snapshot Step 2: start transaction with consistent snapshot [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:42,968 INFO MySQL|company_db_1019|snapshot Step 3: read list of available databases [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:43,002 INFO MySQL|company_db_1019|snapshot list of available databases is: [information_schema, ccc, company_0, company_101225, company_10417, company_104173, company_10441, company_105123, company_1052820, company_1062855, company_10861, company_10957, company_11014, company_11092, company_111237, company_112138, company_113778, company_1138080, company_114728, company_1151916, company_11605, company_11632, company_11827, company_1194254, company_11983, company_11992, company_1228645, company_1231766, company_1232915, company_1280781, company_1298581, company_13264, company_1343679, company_1347911, company_135774, company_1371129, company_1371907, company_1382865, company_1386221, company_1389474, company_1390607, company_1391873, company_1392357, company_1392538, company_1392872, company_1397183, company_1397713, company_1398748, company_1398873, company_1398955, company_1398992, company_1400673, company_1400773, company_1401070, company_1402843, company_1407380, company_1408748, company_1408908, company_1411619, company_1413383, company_1413626, company_1415705, company_1417206, company_1418792, company_1423561, company_1424326, company_1426783, company_1428213, company_1429743, company_1430402, company_1435999, company_1440275, company_14407, company_1441200, company_1442452, company_1442695, company_1443099, company_1444948, company_14452, company_1446067, company_1446147, company_1446283, company_1446980, company_1447379, company_1447693, company_14485, company_1448643, company_1450405, company_1450894, company_1451085, company_14515, company_1451774, company_1454635, company_1456165, company_1456731, company_1457118, company_1457795, company_1457853, company_1461021, company_1464734, company_1465145, company_1465931, company_1467049, company_1467296, company_1467644, company_1469555, company_1470810, company_1472509, company_1472803, company_1479079, company_1479129, company_1480391, company_1480494, company_1481047, company_1482546, company_1486501, company_1487759, company_1488361, company_1489089, company_1489547, company_148986, company_1492611, company_1492777, company_1493646, company_1494320, company_1494951, company_1495139, company_1495987, company_1497097, company_1497372, company_1497513, company_1498388, company_1499295, company_1502118, company_1504148, company_1507548, company_1510211, company_1510827, company_1511156, company_1514501, company_1518023, company_1519892, company_1521411, company_1521487, company_1521886, company_1522187, company_152601, company_1528291, company_1528516, company_1530249, company_1530874, company_1531999, company_1532471, company_1533518, company_1536220, company_1536566, company_1537620, company_1537851, company_153801, company_1539587, company_1539771, company_1540301, company_1541053, company_1542674, company_1542740, company_1542863, company_1542968, company_1543213, company_1546265, company_1547989, company_1548781, company_1548913, company_1549674, company_1550083, company_1550811, company_1551504, company_1552694, company_1552861, company_1553806, company_1555330, company_1556963, company_1557937, company_1558025, company_1558305, company_1558637, company_1558658, company_1563599, company_1564682, company_1564780, company_1566462, company_1566894, company_1567358, company_1568595, company_1569585, company_1570422, company_1570872, company_1571621, company_1573854, company_1574814, company_1575080, company_1575814, company_1576053, company_1580974, company_1582140, company_1583025, company_1583248, company_1584529, company_1586445, company_1587166, company_1589595, company_1589819, company_1590073, company_1590722, company_1591523, company_1592090, company_1594558, company_1596763, company_1599096, company_1600251, company_1600923, company_1603021, company_1603252, company_1603381, company_1606458, company_16075, company_1607592, company_1607616, company_1611851, company_1612324, company_1613552, company_1613712, company_1615883, company_1616702, company_1620612, company_1621280, company_1624023, company_1626009, company_1627516, company_1627773, company_1635594, company_163678, company_1637953, company_1638000, company_1639106, company_1640557, company_1641321, company_1642427, company_1643988, company_1644569, company_1645780, company_1649928, company_1650502, company_1652084, company_1652966, company_1653766, company_1655489, company_1656487, company_1658064, company_1659147, company_1662640, company_1664988, company_1665162, company_1666072, company_1667414, company_1668576, company_1669593, company_16705, company_1671616, company_1676059, company_1677314, company_1678085, company_1678154, company_1678456, company_1679839, company_1683614, company_1683642, company_1683969, company_1683992, company_1685651, company_1687485, company_1687731, company_1688318, company_1689898, company_1690236, company_1691242, company_1691917, company_1692565, company_1693006, company_1693078, company_1694472, company_1695059, company_1696354, company_1702141, company_1702906, company_1703012, company_1703803, company_1704486, company_1705280, company_1706120, company_1707324, company_1707337, company_1707699, company_1711290, company_1714925, company_1716508, company_171905, company_1720540, company_1720659, company_1720715, company_1723225, company_1723612, company_1724296, company_1725068, company_1725265, company_1726692, company_1728034, company_1729532, company_1729833, company_1732958, company_1733084, company_1733781, company_1733881, company_1736042, company_1736483, company_1736604, company_1739979, company_1740027, company_1742223, company_1744227, company_1746010, company_1747356, company_174742, company_1747643, company_1748082, company_1748096, company_1748397, company_1749687, company_1750098, company_1750360, company_1754504, company_1754531, company_1755427, company_1756146, company_1757226, company_1758302, company_1759250, company_1759718, company_1761174, company_1762365, company_1763734, company_17638, company_1764206, company_1764933, company_1767080, company_1767955, company_1769210, company_1770967, company_1771231, company_1773243, company_1776084, company_17764, company_1776799, company_1776859, company_1778135, company_1782623, company_1782868, company_1783602, company_1784408, company_1787065, company_1788199, company_1788894, company_1789861, company_1790840, company_1791485, company_1792549, company_1792735, company_1794093, company_1795215, company_1796336, company_1798391, company_1798608, company_1798730, company_1799273, company_1799416, company_1803126, company_1804939, company_1805562, company_1806539, company_1806954, company_1807498, company_1807619, company_1807655, company_1808684, company_1810867, company_1811490, company_1815018, company_18151, company_1815347, company_1816552, company_1817154, company_1817804, company_1817805, company_1818946, company_1819688, company_1819755, company_1822886, company_1824858, company_1826239, company_1827373, company_1827973, company_1828725, company_1830811, company_1835836, company_1838049, company_1838840, company_1839036, company_1842682, company_1843935, company_1847044, company_1848392, company_1849430, company_1851699, company_1852763, company_1853537, company_1856410, company_1856780, company_1857963, company_1858213, company_1860525, company_1862016, company_1863396, company_1863886, company_1863904, company_1864754, company_1865439, company_1866398, company_1867789, company_1867992, company_1868505, company_1868685, company_1871235, company_1872038, company_1872712, company_1873235, company_1874393, company_1874754, company_1875981, company_1877507, company_1880874, company_1881840, company_1882156, company_1882267, company_1882547, company_1882839, company_1883493, company_1883892, company_1884053, company_1885201, company_1885712, company_1887070, company_1887665, company_1889419, company_1889477, company_1889797, company_1890696, company_1891004, company_1891060, company_1891668, company_1892019, company_1892261, company_1892327, company_1893244, company_1894354, company_1894536, company_1896268, company_1896631, company_1897651, company_1898750, company_1899117, company_1899544, company_1899968, company_1901259, company_1902266, company_1902341, company_19032, company_1904136, company_1904189, company_1904206, company_1904752, company_1905911, company_1906107, company_1906429, company_1907899, company_1908910, company_1909049, company_1910435, company_1910498, company_1910505, company_1910660, company_1912641, company_1913704, company_1914117, company_1915028, company_1915237, company_1915336, company_1915790, company_1916959, company_1917505, company_1918560, company_1918980, company_1919557, company_1919690, company_1920261, company_1924296, company_1925028, company_1925115, company_192544, company_1928573, company_1928972, company_1929879, company_1930217, company_1932423, company_1933596, company_1935222, company_1935720, company_1939457, company_1940171, company_1941081, company_1941089, company_1942418, company_1942629, company_1943896, company_194466, company_1945937, company_1946203, company_1946808, company_1947893, company_1948380, company_1948838, company_1948956, company_1951096, company_1952184, company_1954648, company_1955585, company_1956983, company_1957154, company_1957391, company_1958693, company_1962788, company_1964223, company_1965259, company_1965565, company_1966162, company_1968500, company_1968694, company_1970325, company_1970726, company_1970801, company_1972362, company_1973104, company_1973335, company_1973562, company_1973958, company_1974674, company_1974861, company_1975963, company_1976040, company_1977059, company_1978539, company_1979112, company_1979960, company_1980895, company_1981338, company_1983551, company_1984160, company_1984334, company_1985186, company_1985811, company_1985823, company_1986260, company_1986831, company_1987232, company_1989659, company_199, company_1991446, company_1993026, company_1993418, company_1994736, company_1994799, company_1995486, company_1995731, company_199661, company_1998629, company_1998796, company_1999063, company_1999258, company_1999508, company_2001841, company_2002198, company_2003095, company_2004193, company_2005125, company_2007217, company_2007649, company_2008713, company_2009346, company_2009367, company_2010367, company_2010841, company_2010890, company_2011032, company_2011117, company_2011387, company_2011618, company_2012990, company_2013851, company_2014806, company_2014967, company_2016506, company_2022162, company_2022764, company_2024381, company_2025537, company_2025744, company_2026188, company_2026460, company_2027172, company_2027671, company_2029981, company_2030322, company_2032075, company_2033293, company_2034371, company_2036379, company_2036944, company_2037483, company_2039338, company_204, company_2042483, company_2043692, company_2044248, company_2044714, company_2045106, company_2045486, company_20472, company_2047236, company_2048357, company_2049309, company_2050174, company_2051630, company_2052087, company_2054811, company_2056208, company_2056483, company_20568, company_2058247, company_2063523, company_2063810, company_2066281, company_2069384, company_2071246, company_2071954, company_2071972, company_2073270, company_2073701, company_2074261, company_2076685, company_2076795, company_2077054, company_2077358, company_2078097, company_2078114, company_2080603, company_2081152, company_2081662, company_2084250, company_2085512, company_2086178, company_2087337, company_2088697, company_2089180, company_2090020, company_2090665, company_2091404, company_2098077, company_2098414, company_2107434, company_2108400, company_2110047, company_2110642, company_21111, company_2111123, company_2112526, company_2115669, company_2115771, company_2117195, company_2117236, company_2117556, company_2118315, company_2119229, company_2121227, company_2121681, company_2121856, company_2123187, company_2123205, company_2123880, company_2124906, company_2125503, company_2125977, company_2127687, company_2127883, company_2128381, company_2130795, company_2131684, company_2135563, company_2136423, company_2136792, company_2137662, company_2140152, company_2140432, company_2142266, company_2142479, company_2142927, company_2144229, company_2145, company_2145048, company_2146028, company_2146209, company_2146480, company_2146832, company_2147859, company_215, company_2150, company_2151845, company_2151984, company_2152265, company_2152780, company_2153, company_2153300, company_2154469, company_2155520, company_2156861, company_2157, company_2161938, company_2164143, company_2165207, company_2166444, company_2166521, company_2166633, company_2167392, company_2168974, company_2169370, company_2170343, company_2171578, company_2172893, company_2175406, company_2177394, company_2178423, company_2178445, company_2179751, company_2181560, company_2184906, company_2187325, company_2188620, company_2189295, company_2190898, company_2191514, company_2193285, company_2193996, company_2195763, company_2196021, company_2196376, company_2197191, company_2199820, company_2200082, company_2201409, company_2205241, company_2205434, company_2205787, company_2206449, company_2206844, company_2207978, company_2208906, company_2209963, company_2210089, company_2210176, company_2210278, company_2210393, company_2210775, company_2211400, company_2212014, company_2213249, company_2214760, company_2215251, company_2216651, company_2216662, company_2219127, company_22200, company_2220166, company_2220674, company_2220934, company_2221697, company_2221804, company_2222957, company_2223148, company_2223607, company_2224006, company_2224205, company_2224420, company_2224440, company_2224994, company_2225805, company_2225953, company_2226102, company_2226172, company_2227591, company_2227723, company_2228564, company_2228794, company_2228930, company_2229140, company_2229453, company_2229763, company_2231518, company_2232518, company_2232679, company_2232976, company_2235004, company_2235186, company_2235409, company_2235503, company_2235795, company_2236448, company_2236887, company_2237334, company_2237929, company_2238328, company_2238545, company_2238681, company_2239073, company_2239511, company_2239591, company_2239673, company_2239892, company_2240184, company_2240639, company_2241173, company_2241429, company_2241597, company_2241843, company_2242241, company_2242412, company_2242493, company_2242664, company_2242837, company_2243924, company_2244503, company_2244559, company_2244783, company_2245657, company_2245693, company_2245779, company_2245832, company_2246017, company_2246451, company_2246519, company_2246836, company_2247305, company_2247380, company_2247431, company_2247844, company_2247879, company_2248975, company_2249342, company_2249724, company_2251090, company_2251166, company_2251552, company_2251769, company_2251909, company_2252181, company_2252282, company_2252644, company_2252671, company_2252779, company_2253287, company_2253329, company_2253372, company_2253399, company_2253451, company_2253514, company_2253528, company_2253955, company_2254072, company_2254291, company_2254522, company_2254646, company_2254730, company_2254767, company_2255089, company_2255485, company_2255495, company_2255506, company_2255555, company_2255850, company_2255975, company_2256011, company_2256032, company_2256039, company_2256125, company_2256255, company_2256375, company_2256402, company_2256452, company_2256535, company_2256543, company_2256571, company_2256774, company_2256878, company_2256976, company_2257089, company_2257119, company_2257130, company_2257145, company_2257193, company_2257271, company_2257406, company_2257469, company_2257553, company_2257592, company_2257683, company_2257691, company_2257889, company_2257894, company_2258054, company_2258096, company_2258160, company_2258197, company_2258239, company_2258314, company_2258335, company_2258342, company_2258356, company_2258510, company_2258565, company_2258691, company_2258873, company_2258895, company_2258972, company_2258986, company_2258993, company_2259072, company_2259170, company_2259181, company_2259209, company_2259237, company_2259252, company_2259272, company_2259301, company_2259429, company_2259461, company_2259632, company_2259832, company_2259840, company_2259903, company_2259938, company_2259993, company_2260197, company_2260224, company_2260253, company_2260269, company_2260322, company_2260393, company_2260414, company_2260427, company_2260435, company_2260463, company_2260472, company_2260514, company_2260532, company_2260535, company_2260540, company_2260575, company_2260584, company_2260619, company_2260630, company_2260633, company_2260644, company_2260661, company_2260731, company_2260750, company_2260763, company_2260819, company_2260946, company_2260981, company_2261324, company_2261415, company_2261431, company_2261463, company_2261470, company_2261610, company_2261625, company_2261652, company_2261667, company_2261680, company_2261718, company_2261835, company_2261844, company_2261876, company_2261890, company_2262016, company_2262037, company_2262150, company_2262173, company_2262205, company_2262229, company_2262234, company_2262240, company_2262247, company_2262264, company_2262345, company_2262352, company_2262395, company_2262465, company_2262492, company_2262509, company_2262551, company_2262576, company_2262607, company_2262619, company_2262628, company_2262639, company_2262642, company_2262656, company_2262710, company_2262726, company_2262803, company_2262821, company_2262871, company_2262884, company_2262901, company_2262926, company_2262990, company_2263024, company_2263046, company_2263052, company_2263059, company_2263102, company_2263130, company_2263146, company_2263171, company_2263193, company_2263207, company_2263223, company_2263263, company_2263305, company_2263328, company_2263354, company_2263361, company_2263370, company_2263377, company_2263382, company_2263424, company_2263431, company_2263445, company_2263493, company_2263503, company_2263510, company_2263535, company_2263738, company_2263762, company_2263829, company_2263843, company_2263860, company_2263867, company_2263886, company_2263895, company_2263923, company_2263948, company_2263962, company_2263965, company_2263972, company_2264042, company_2264095, company_2264112, company_2264151, company_2264193, company_2264203, company_2264242, company_2264245, company_2264259, company_2264285, company_2264298, company_2264308, company_2264329, company_2264341, company_2264385, company_2264392, company_2264403, company_2264413, company_2264425, company_2264439, company_2264452, company_2264459, company_2264469, company_2264481, company_2264516, company_2264525, company_2264532, company_2264537, company_2264544, company_2264578, company_2264588, company_2264602, company_2264607, company_2264627, company_2264644, company_2264658, company_2264693, company_2264704, company_2264711, company_2264728, company_2264739, company_2264747, company_2264777, company_2264805, company_2264817, company_2264852, company_2264858, company_2264865, company_2264879, company_2264887, company_2264900, company_2264910, company_2264921, company_2264929, company_2264949, company_2264963, company_2264980, company_2264991, company_2265029, company_2265040, company_2265054, company_2265069, company_2265085, company_2265096, company_2265132, company_2265160, company_2265188, company_2265202, company_2265230, company_2265244, company_2265271, company_2265279, company_2265288, company_2265299, company_2265327, company_2265337, company_2265351, company_2265372, company_2265414, company_2265432, company_2265503, company_2265516, company_2265530, company_2265544, company_2265554, company_2265568, company_2265575, company_2265589, company_2265600, company_2265614, company_2265624, company_2265636, company_2265645, company_2265664, company_2265680, company_2265687, company_2265694, company_2265719, company_2265726, company_2265740, company_2265750, company_2265771, company_2265783, company_2265790, company_2265803, company_2265827, company_2265860, company_2265874, company_2265911, company_2265918, company_2265930, company_2265936, company_2265979, company_2265988, company_2266000, company_2266007, company_2266027, company_2266049, company_2266069, company_2266086, company_2266098, company_2266119, company_2266128, company_2266140, company_2266149, company_2266156, company_2266167, company_2266198, company_2266209, company_2266216, company_2266224, company_2266231, company_2266240, company_2266254, company_2266261, company_2266268, company_2266279, company_2266293, company_2266303, company_2266315, company_2266322, company_2266335, company_2266342, company_2266359, company_2266380, company_2266392, company_2266405, company_2266413, company_2266433, company_2266436, company_2266450, company_2266462, company_2266478, company_2266483, company_2266492, company_2266506, company_2266518, company_2266531, company_2266548, company_2266562, company_2266574, company_2266587, company_2266594, company_2266632, company_2266646, company_2266658, company_2266667, company_2266672, company_2266679, company_2266699, company_2266714, company_2266728, company_2266749, company_2266762, company_2266776, company_2266783, company_2266793, company_2266814, company_2266826, company_2266833, company_2266842, company_2266856, company_2266861, company_2266874, company_2266877, company_2266888, company_2266896, company_2266909, company_2266912, company_2266931, company_2266944, company_2266951, company_2266966, company_2266982, company_2267007, company_2267021, company_2267035, company_2267049, company_2267059, company_2267066, company_2267080, company_2267092, company_2267099, company_2267119, company_2267122, company_2267127, company_2267143, company_2267154, company_2267161, company_2267168, company_2267182, company_2267189, company_2267196, company_2267204, company_2267211, company_2267225, company_2267238, company_2267245, company_2267253, company_2267266, company_2267280, company_2267288, company_2267301, company_2267304, company_2267323, company_2267332, company_2267337, company_2267350, company_2267357, company_2267365, company_2267378, company_2267386, company_2267393, company_2267400, company_2267407, company_2267420, company_2267427, company_2267430, company_2267437, company_2267449, company_2267458, company_2267469, company_2267477, company_2267491, company_2267497, company_2267505, company_2267511, company_2267519, company_2267533, company_2267542, company_2267554, company_2267563, company_2267570, company_2267577, company_2267582, company_2267589, company_2267602, company_2267609, company_2267616, company_2267626, company_2267633, company_2267644, company_2267652, company_2267659, company_2267661, company_2267665, company_2267675, company_2267686, company_2267696, company_2267703, company_2267714, company_2267722, company_2267729, company_2267742, company_2267749, company_2267756, company_2267764, company_2267770, company_2267784, company_2267798, company_2267812, company_2267819, company_2267822, company_2267827, company_2267833, company_2267840, company_2267850, company_2267868, company_2267892, company_2267903, company_2267904, company_2267906, company_2267910, company_2267913, company_2267924, company_2267925, company_2267945, company_2267946, company_2267953, company_2267960, company_2267973, company_2267980, company_2267994, company_2268004, company_2268016, company_2268025, company_2268036, company_2268044, company_2268053, company_2268067, company_2268086, company_2268092, company_2268099, company_2268106, company_2268116, company_2268128, company_2268142, company_2268156, company_2268170, company_2268177, company_2268191, company_2268207, company_2268218, company_2268225, company_2268235, company_2268249, company_2268268, company_2268275, company_2268288, company_2268296, company_2268305, company_2268310, company_2268312, company_2268319, company_2268326, company_2268331, company_2268338, company_2268340, company_2268354, company_2268372, company_2268380, company_2268401, company_2268408, company_2268417, company_2268431, company_2268442, company_2268450, company_2268464, company_2268473, company_2268484, company_2268491, company_2268499, company_2268506, company_2268513, company_2268520, company_2268534, company_2268541, company_2268554, company_2268568, company_2268578, company_2268585, company_2268596, company_2268603, company_2268613, company_2268620, company_2268645, company_2268653, company_2268662, company_2268673, company_2268683, company_2268695, company_2268702, company_2268723, company_2268732, company_2268744, company_2268753, company_2268764, company_2268774, company_2268779, company_2268788, company_2268793, company_2268802, company_2268813, company_2268823, company_2268830, company_2268841, company_2268849, company_2268858, company_2268865, company_2268870, company_2268879, company_2268890, company_2268900, company_2268911, company_2268918, company_2268928, company_2268940, company_2268946, company_2268953, company_2268961, company_2268967, company_2268974, company_2268988, company_2268996, company_2269016, company_2269030, company_2269038, company_2269045, company_2269051, company_2269058, company_2269073, company_2269089, company_2269100, company_2269108, company_2269122, company_2269142, company_2269152, company_2269159, company_2269164, company_2269255, company_2269290, company_2269306, company_2269318, company_2269327, company_2269339, company_2269353, company_2269360, company_2269369, company_2269383, company_2269394, company_2269402, company_2269415, company_2269422, company_2269430, company_2269439, company_2269446, company_2269457, company_2269471, company_2269479, company_2269481, company_2269485, company_2269495, company_2269507, company_2269514, company_2269528, company_2269534, company_2269542, company_2269549, company_2269558, company_2269569, company_2269579, company_2269590, company_2269597, company_2269607, company_2269614, company_2269626, company_2269635, company_2269647, company_2269661, company_2269674, company_2269682, company_2269695, company_2269703, company_2269710, company_2269719, company_2269731, company_2269744, company_2269751, company_2269758, company_2269768, company_2269782, company_2269793, company_2269800, company_2269815, company_2269857, company_2269864, company_2269877, company_2269891, company_2269899, company_2269901, company_2269913, company_2269920, company_2269933, company_2269947, company_2269948, company_2269962, company_2269971, company_2269983, company_2269996, company_227, company_2270006, company_2270011, company_2270020, company_2270027, company_2270034, company_2270045, company_2270052, company_2270059, company_2270066, company_2270076, company_2270083, company_2270094, company_2270102, company_2270108, company_2270115, company_2270129, company_2270137, company_2270144, company_2270151, company_2270160, company_2270171, company_2270185, company_2270193, company_2270200, company_2270213, company_2270223, company_2270230, company_2270241, company_2270249, company_2270263, company_2270277, company_2270284, company_2270291, company_2270304, company_2270312, company_2270325, company_2270339, company_2270346, company_2270354, company_2270363, company_2270370, company_2270374, company_2270375, company_2270381, company_2270384, company_2270389, company_2270395, company_2270402, company_2270405, company_2270410, company_2270417, company_2270419, company_2270424, company_2270430, company_2270431, company_2270438, company_2270451, company_2270465, company_2270473, company_2270482, company_2270489, company_2270496, company_2270507, company_2270515, company_2270521, company_2270528, company_2270536, company_2270549, company_2270557, company_2270570, company_2270584, company_2270592, company_2270601, company_2270613, company_2270627, company_2270643, company_2270655, company_2270668, company_2270706, company_2270746, company_2270780, company_2270790, company_2270804, company_2270815, company_2270822, company_2270830, company_2270844, company_2270857, company_2270860, company_2270874, company_2270886, company_2270902, company_2270907, company_2270913, company_2270920, company_2270927, company_2270955, company_2270958, company_2270970, company_2271040, company_2271046, company_2271047, company_2271053, company_2271054, company_2271056, company_2271063, company_2271068, company_2271075, company_2271081, company_2271082, company_2271089, company_2271096, company_2271103, company_2271109, company_2271110, company_2271116, company_2271124, company_2271138, company_2271144, company_2271147, company_2271161, company_2271172, company_2271182, company_2271193, company_2271201, company_2271210, company_2271224, company_2271238, company_2271249, company_2271263, company_2271273, company_2271287, company_2271298, company_2271313, company_2271327, company_2271334, company_2271347, company_2271361, company_2271378, company_2271392, company_2271406, company_2271418, company_2271431, company_2271446, company_2271459, company_2271476, company_2271490, company_2271497, company_2271515, company_2271525, company_2271539, company_2271544, company_2271550, company_2271557, company_2271567, company_2271579, company_2271588, company_2271600, company_2271607, company_2271614, company_2271627, company_2271634, company_2271642, company_2271651, company_2271658, company_2271669, company_2271676, company_2271679, company_2271690, company_2271704, company_2271707, company_2271718, company_2271728, company_2271735, company_2271746, company_2271756, company_2271768, company_2271777, company_2271788, company_2271796, company_2271805, company_2271816, company_2271824, company_2271831, company_2271845, company_2271858, company_2271866, company_2271875, company_2271886, company_2271894, company_2271907, company_2271915, company_2271922, company_2271931, company_2271936, company_2271945, company_2271956, company_2271963, company_2271977, company_2271984, company_2271994, company_22749, company_231, company_23367, company_240, company_242587, company_243, company_249, company_252546, company_262242, company_267635, company_270, company_272, company_273, company_276, company_277, company_280, company_284, company_285, company_293, company_297, company_300, company_313, company_314, company_31696, company_317, company_318, company_321, company_322, company_327626, company_328180, company_330935, company_3348, company_336316, company_345696, company_3528, company_355673, company_363735, company_365180, company_365196, company_366, company_368, company_371058, company_37492, company_378124, company_3798, company_382, company_387824, company_3912, company_397831, company_404246, company_41, company_415173, company_417069, company_417311, company_41857, company_431974, company_432263, company_432949, company_437358, company_440323, company_442588, company_444076, company_445, company_457, company_466405, company_487, company_4896, company_4899, company_490, company_494240, company_4953, company_49954, company_5, company_52249, company_52875, company_53265, company_53529, company_5394, company_54710, company_54777, company_55508, company_56444, company_5663, company_5712, company_5715, company_5723, company_595192, company_5958, company_608, company_608298, company_611, company_62849, company_6319, company_64604, company_6577, company_6827, company_7120, company_7195, company_74074, company_7438, company_7439, company_7477, company_77482, company_791657, company_7969, company_800071, company_810, company_810196, company_814553, company_818151, company_8222, company_826081, company_8262, company_8374, company_8385, company_852817, company_855, company_862241, company_8674, company_87163, company_87166, company_87176, company_901620, company_917182, company_940397, company_978787, mysql, performance_schema, sys] [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:43,004 INFO MySQL|company_db_1019|snapshot Step 4: read list of available tables in each database [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:43,014 INFO MySQL|company_db_1019|snapshot 'company_0.3rd_party_connections' is filtered out, discarding [io.debezium.connector.mysql.SnapshotReader] ... A lot here!!! ... 2018-05-07 08:49:53,393 INFO MySQL|company_db_1019|snapshot 'performance_schema.variables_by_thread' is filtered out, discarding [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:53,396 INFO MySQL|company_db_1019|snapshot 'sys.sys_config' is filtered out, discarding [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:53,399 INFO MySQL|company_db_1019|snapshot snapshot continuing with database(s): [company_2256402, company_2255555, company_1728034, company_2242241, company_1584529, company_2270706, company_2268870, company_2267542, company_2263171, company_2266216, company_2268879, company_2266699, company_1696354, company_1974861, company_1626009, company_2253372, company_1638000, company_2259903, company_1720540, company_2256878, company_1798391, company_2265372, company_2264042, company_2267554, company_1928972, company_2269731, company_2266224, company_2268401, company_1492777, company_2188620, company_2268408, company_1494951, company_2239073, company_1658064, company_2033293, company_2268890, company_153801, company_2267563, company_2266231, company_1553806, company_2269744, company_1573854, company_1546265, company_2268417, company_1887070, company_1691917, company_13264, company_1603381, company_1402843, company_2011032, company_1386221, company_2251166, company_1695059, company_2118315, company_2267570, company_1469555, company_2263146, company_2269751, company_2266240, company_17638, company_2022162, company_1902341, company_1973562, company_2270746, company_2267577, company_1493646, company_174742, company_1151916, company_2269758, company_11092, company_1885712, company_1935222, company_2268431, company_2267582, company_2266254, company_2263130, company_1627773, company_2267589, company_2269768, company_2271600, company_1400673, company_1583248, company_2205241, company_1748096, company_1723612, company_1916959, company_2266261, company_2253329, company_2255506, company_2268442, company_2271607, company_1811490, company_2048357, company_113778, company_2271614, company_2266268, company_1973104, company_2267119, company_2036379, company_1863904, company_2254646, company_2255975, company_2268450, company_1465145, company_355673, company_2264095, company_2262264, company_2226172, company_2269782, company_2267122, company_2267127, company_2271627, company_2266279, company_2269306, company_2242664, company_1688318, company_1733881, company_1790840, company_2187325, company_1789861, company_2263102, company_2268464, company_1415705, company_2269793, company_2270304, company_2024381, company_2271634, company_2269318, company_2270780, company_2261835, company_6319, company_2260981, company_1828725, company_192544, company_2267945, company_2259993, company_2267946, company_2264439, company_1558637, company_1782868, company_2236887, company_2014967, company_1788199, company_2224420, company_1547989, company_1747643, company_1571621, company_2265771, company_2115669, company_2268802, company_2267953, company_1418792, company_2254291, company_1941089, company_1611851, company_1679839, company_1806954, company_1941081, company_2264452, company_2265783, company_2267960, company_2266632, company_2268813, company_2264459, company_1558658, company_1758302, company_1948956, company_242587, company_1685651, company_940397, company_2265790, company_1576053, company_1489547, company_2267973, company_2264469, company_2266646, company_2268823, company_2073701, company_1818946, company_2256452, company_800071, company_2260946, company_2235503, company_1723225, company_1964223, company_1799273, company_2267980, company_2268830, company_1892019, company_2266658, company_2267505, company_2265327, company_2071954, company_1371129, company_1965565, company_2264481, company_1875981, company_2267994, company_2267511, company_2268841, company_2266667, company_2265337, company_1952184, company_2127687, company_2267519, company_2268849, company_1985186, company_1882267, company_2253399, company_1848392, company_52875, company_1843935, company_2259938, company_2266672, company_2245779, company_1606458, company_2263193, company_2268858, company_494240, company_2266679, company_2269703, company_2071972, company_1442452, company_1440275, company_1397713, company_2265351, company_2268865, company_2267533, company_2269710, company_2078114, company_1847044, company_2266209, company_2269719, company_1194254, company_1511156, company_2090665, company_1968500, company_327626, company_53265, company_2125977, company_2262642, company_440323, company_2263972, company_2260463, company_1806539, company_1655489, company_1764933, company_1683969, company_2271124, company_2270277, company_3798, company_2262639, company_2263965, company_2269290, company_2125503, company_2263962, company_6827, company_1580974, company_1904189, company_1872038, company_1519892, company_2271138, company_2238545, company_1815018, company_2259461, company_2270284, company_2262628, company_1446067, company_2270291, company_2235004, company_1899544, company_2264852, company_2271147, company_1530249, company_2271144, company_2257271, company_2264858, company_2262619, company_1771231, company_2263948, company_1946808, company_2260435, company_2086178, company_2213249, company_1999258, company_2264865, company_3348, company_1683992, company_1919690, company_2255089, company_2265719, company_11827, company_2262607, company_2260427, company_1428213, company_1726692, company_2110047, company_1899968, company_1486501, company_2050174, company_2267903, company_2264879, company_2265726, company_2267904, company_2267906, company_2271161, company_2259429, company_1945937, company_2263923, company_2260414, company_2076795, company_2267910, company_2264403, company_2264887, company_2267913, company_1587166, company_1884053, company_1736483, company_2271172, company_2151845, company_1667414, company_2271182, company_2167392, company_2247431, company_1839036, company_2265740, company_1842682, company_363735, company_1464734, company_2264413, company_2267925, company_2267924, company_2258565, company_1942418, company_2271193, company_1532471, company_2265750, company_1739979, company_2210176, company_2264425, company_2146480, company_2256375, company_2261718, company_1687485, company_2146832, company_2178423, company_2262247, company_2269682, company_2179751, company_2268354, company_2267021, company_2262240, company_1480391, company_1977059, company_2259072, company_2271525, company_442588, company_1750360, company_2142479, company_2039338, company_1510211, company_1889797, company_2166444, company_163678, company_2231518, company_2262234, company_2267035, company_2152265, company_2269695, company_2271539, company_1928573, company_2119229, company_1231766, company_1736042, company_2270200, company_2228794, company_2262229, company_1448643, company_1457118, company_14515, company_2268372, company_1592090, company_2073270, company_1392872, company_1915237, company_1973958, company_2266198, company_1904136, company_2267049, company_2271544, company_2270213, company_1891668, company_1929879, company_2268380, company_1807498, company_16705, company_11014, company_2154469, company_2029981, company_1615883, company_1762365, company_1867992, company_2267059, company_2270223, company_2271557, company_1748082, company_1995731, company_2271550, company_2258197, company_2251552, company_1447379, company_2262205, company_2263535, company_1612324, company_2267066, company_2005125, company_2271567, company_1531999, company_2270230, company_1371907, company_1908910, company_2044714, company_1482546, company_2269255, company_2270249, company_1678154, company_2271579, company_2270241, company_2243924, company_1590722, company_1925028, company_2264805, company_1690236, company_1732958, company_1856410, company_2267080, company_1986831, company_2178445, company_1616702, company_2263510, company_1704486, company_1824858, company_2258160, company_2271109, company_2271588, company_2271103, company_5958, company_2264817, company_1795215, company_1881840, company_1798730, company_2226102, company_2261324, company_2262656, company_2263503, company_2267092, company_1563599, company_2267099, company_1899117, company_2260472, company_2239892, company_1542674, company_1621280, company_2144229, company_2271116, company_2270263, company_199661, company_2271110, company_2197191, company_2196376, company_1536566, company_1742223, company_2117556, company_2240184, company_2264151, company_1706120, company_2267661, company_14452, company_2268996, company_2268513, company_2266335, company_1705280, company_2267665, company_2270830, company_2223607, company_2078097, company_2152780, company_2268520, company_2266342, company_2267675, company_2270844, company_1607616, company_2269857, company_7120, company_1957154, company_1603252, company_1446980, company_1984334, company_608, company_1590073, company_2267686, company_2268534, company_2267204, company_2271704, company_2269864, company_2270857, company_2266359, company_1390607, company_2265029, company_2011387, company_1400773, company_2256976, company_2210775, company_2268541, company_2267211, company_2263263, company_2271707, company_14485, company_2267696, company_2269877, company_1451085, company_2270860, company_101225, company_2253451, company_1858213, company_1488361, company_2264193, company_2265040, company_2232518, company_2271718, company_2245832, company_2244503, company_2268554, company_1972362, company_2267225, company_2269402, company_2270874, company_1995486, company_1909049, company_1733781, company_2166521, company_2266380, company_2269891, company_1528516, company_2063810, company_2271728, company_2262395, company_2265054, company_1413626, company_2271735, company_2268568, company_2269415, company_2269899, company_1905911, company_2165207, company_2270405, company_1767955, company_2026460, company_2267238, company_2270402, company_2270886, company_23367, company_2089180, company_2232976, company_2254767, company_1827973, company_2266392, company_444076, company_2269422, company_1521487, company_2268578, company_2271746, company_328180, company_2267245, company_2265069, company_2270417, company_2270410, company_1740027, company_7195, company_1860525, company_1472803, company_1788894, company_2263223, company_2267253, company_2268585, company_2260197, company_2270419, company_2269430, company_2268106, company_2271756, company_2269439, company_2270424, company_365180, company_2256125, company_2262803, company_2115771, company_1783602, company_2044248, company_1894354, company_1871235, company_1398992, company_2268911, company_2259632, company_2260619, company_2268918, company_2146028, company_2081662, company_1910498, company_1933596, company_2201409, company_2265414, company_2248975, company_2268928, company_2266749, company_10957, company_1912641, company_1792549, company_1920261, company_2267602, company_2264578, company_2224994, company_1694472, company_2267609, company_1550811, company_1570872, company_2266762, company_2142927, company_2265432, company_2268940, company_1776084, company_2264588, company_2268946, company_1441200, company_2220166, company_2267616, company_2256571, company_437358, company_1537851, company_1398955, company_2268953, company_2269800, company_2264112, company_1568595, company_2098077, company_2266776, company_2267626, company_2257894, company_1620612, company_2175406, company_1558305, company_1642427, company_1687731, company_5394, company_2257406, company_2257889, company_2025537, company_2056208, company_2219127, company_2266783, company_2267633, company_2268961, company_2268967, company_2266303, company_2269815, company_1574814, company_2193285, company_2256543, company_1803126, company_1935720, company_2199820, company_2270804, company_2266793, company_1407380, company_2225805, company_2268974, company_1570422, company_2267644, company_1826239, company_2266315, company_2252181, company_1989659, company_2256535, company_365196, company_1978539, company_2045106, company_2270815, company_1910435, company_2266322, company_2267652, company_2270822, company_2244559, company_1874754, company_2268506, company_2267659, company_2268988, company_1456731, company_199, company_1649928, company_10417, company_2004193, company_431974, company_2260584, company_2261431, company_608298, company_417311, company_2271249, company_1495139, company_2270395, company_2265803, company_917182, company_2088697, company_1556963, company_1784408, company_1637953, company_2212014, company_2268086, company_2260575, company_1665162, company_2239511, company_2264963, company_2237334, company_1767080, company_74074, company_1392357, company_2261415, company_2268092, company_1507548, company_2261890, company_2268099, company_1910505, company_2223148, company_284, company_285, company_2265827, company_387824, company_2271263, company_280, company_2091404, company_1749687, company_1943896, company_277, company_2258239, company_10441, company_1678456, company_2264980, company_2007217, company_2224006, company_1851699, company_276, company_273, company_272, company_2271273, company_270, company_1991446, company_2262726, company_227, company_2261876, company_1898750, company_2260540, company_2087337, company_2136792, company_2076685, company_2264991, company_1543213, company_2271287, company_2264516, company_2256039, company_1769210, company_215, company_1865439, company_2236448, company_2260535, company_2260532, company_2262710, company_10861, company_2210278, company_2014806, company_2172893, company_1548913, company_1062855, company_2264525, company_2271298, company_2258691, company_2256032, company_330935, company_249, company_2042483, company_2137662, company_1541053, company_2265860, company_2264532, company_2264537, company_2266714, company_243, company_240, company_2010890, company_1408748, company_2260514, company_901620, company_2261844, company_2189295, company_1968694, company_2224440, company_52249, company_1417206, company_2249724, company_2265874, company_2264544, company_2268900, company_231, company_1887665, company_2266728, company_1138080, company_2256011, company_1443099, company_1703012, company_2266293, company_2267143, company_1589819, company_2268473, company_1600251, company_2269327, company_2270312, company_2271642, company_1678085, company_2270790, company_2254730, company_2084250, company_0, company_2263207, company_2191514, company_2267154, company_2262352, company_2268484, company_2259181, company_2271658, company_2268004, company_1868505, company_2269339, company_2270325, company_5, company_2271651, company_2239591, company_2241429, company_2229763, company_204, company_1889419, company_1702141, company_2267161, company_2262345, company_1669593, company_2268491, company_1725265, company_2259170, company_2271669, company_2267168, company_2268499, company_2270339, company_2268016, company_1542740, company_2098414, company_2221804, company_1874393, company_2037483, company_1650502, company_14407, company_1666072, company_2268025, company_2269353, company_2227591, company_2271679, company_1906429, company_2271676, company_2270346, company_1539587, company_49954, company_2264900, company_4953, company_1424326, company_2121681, company_1479079, company_2117195, company_2200082, company_2267182, company_2269360, company_2268036, company_1915336, company_2261470, company_2267189, company_1397183, company_2054811, company_2269369, company_2264910, company_21111, company_2271201, company_2270354, company_2220934, company_2235186, company_1889477, company_611, company_2121227, company_1882839, company_2261463, company_2267196, company_2249342, company_2268044, company_1391873, company_1924296, company_1521411, company_2010841, company_2264921, company_2271210, company_2270363, company_2123880, company_2271690, company_2264929, company_1776859, company_1446147, company_1915790, company_2268053, company_1467049, company_2269383, company_1480494, company_1521886, company_1613552, company_2271224, company_2007649, company_1798608, company_2270374, company_2270375, company_1925115, company_2207978, company_2270370, company_1748397, company_2205787, company_2147859, company_2269394, company_1917505, company_371058, company_2268067, company_1232915, company_2270389, company_2271238, company_2270384, company_1495987, company_2241843, company_1904206, company_2270381, company_2264949, company_2238681, company_2232679, company_2081152, company_1707337, company_2047236, company_2085512, company_2266450, company_1575814, company_2267301, company_1866398, company_1904752, company_2267784, company_2269962, company_2270955, company_2267304, company_64604, company_1640557, company_2252282, company_791657, company_1755427, company_2016506, company_1435999, company_2269971, company_2271805, company_2270958, company_2264285, company_2265132, company_2266462, company_2268645, company_2246836, company_2267798, company_1975963, company_1536220, company_2153300, company_2271816, company_2269983, company_1804939, company_2267323, company_2264298, company_2266478, company_2268653, company_2271824, company_1594558, company_2220674, company_2269507, company_1664988, company_2270970, company_2034371, company_1659147, company_1707324, company_2266483, company_2268662, company_2267332, company_2266000, company_2263382, company_2269514, company_2269996, company_2266007, company_2267337, company_2271831, company_1901259, company_252546, company_1423561, company_1776799, company_2117236, company_2265160, company_2266492, company_2263377, company_2268673, company_2270507, company_2271845, company_2263370, company_2270515, company_2269528, company_1973335, company_2241597, company_3912, company_8385, company_1624023, company_1582140, company_1558025, company_2262037, company_2267350, company_1998629, company_2268683, company_2263361, company_2266027, company_2271858, company_2267357, company_2269534, company_2027671, company_2270521, company_1974674, company_2268207, company_1754531, company_8374, company_135774, company_1999508, company_2263354, company_2268695, company_2269542, company_2270528, company_2267365, company_2155520, company_2265188, company_2128381, company_2270536, company_2271866, company_1539771, company_2268218, company_2269549, company_1702906, company_1457795, company_1817805, company_62849, company_1799416, company_1817804, company_1689898, company_2229453, company_2196021, company_2262016, company_1652966, company_2262492, company_2267378, company_2269558, company_1596763, company_2266049, company_2268225, company_2270549, company_1947893, company_2242412, company_2271875, company_2166633, company_2262926, company_1693006, company_267635, company_2151984, company_2090020, company_2077054, company_1398873, company_2009367, company_2266856, company_2267703, company_1778135, company_2260731, company_1782623, company_2266861, company_2265530, company_2264203, company_2267714, company_2127883, company_2235795, company_2010367, company_2258895, company_345696, company_2012990, company_6577, company_2171578, company_2262901, company_2009346, company_53529, company_1714925, company_2264693, company_2266874, company_2265544, company_2267722, company_595192, company_2266877, company_2269901, company_2267729, company_2257553, company_1589595, company_1849430, company_1454635, company_2265554, company_2269913, company_1567358, company_2107434, company_2266405, company_2266888, company_1757226, company_1830811, company_1607592, company_2258873, company_1703803, company_2013851, company_2270907, company_2270902, company_2237929, company_2269920, company_415173, company_2266896, company_2267742, company_2266413, company_2265568, company_2267749, company_37492, company_7438, company_7439, company_1892261, company_2045486, company_2270913, company_2264242, company_2270920, company_2265575, company_2264245, company_2267756, company_2269933, company_2268603, company_297, company_2225953, company_1951096, company_1979960, company_293, company_1497372, company_1896631, company_2241173, company_1639106, company_2270927, company_1569585, company_2266433, company_2267764, company_2266436, company_1816552, company_2265589, company_2269947, company_2264259, company_2268613, company_1787065, company_2269948, company_2140432, company_7477, company_1600923, company_1693078, company_1442695, company_378124, company_1807619, company_2267770, company_1986260, company_2242493, company_2268620, company_2263738, company_2259237, company_2260224, company_1429743, company_2268191, company_2262884, company_1747356, company_2269045, company_432949, company_1566894, company_16075, company_2270034, company_382, company_2271361, company_2269051, company_11632, company_2262871, company_1896268, company_1932423, company_2269058, company_2080603, company_2011618, company_2265930, company_2271378, company_2264602, company_1557937, company_4899, company_1853537, company_2270045, company_1413383, company_2265936, company_4896, company_2264607, company_1965259, company_336316, company_1461021, company_171905, company_2135563, company_1980895, company_2270059, company_2177394, company_2208906, company_1533518, company_2270052, company_2259209, company_1550083, company_1807655, company_2269073, company_1510827, company_2146209, company_1504148, company_2111123, company_2027172, company_2270066, company_2258356, company_2264627, company_2271392, company_2228930, company_7969, company_1481047, company_2260661, company_2269089, company_2170343, company_2001841, company_2214760, company_2258342, company_2266814, company_2270076, company_2036944, company_1444948, company_1644569, company_2258335, company_1954648, company_1930217, company_2136423, company_2210393, company_2264644, company_2265979, company_2266826, company_2270083, company_1907899, company_11605, company_54777, company_105123, company_2260644, company_31696, company_368, company_1862016, company_2262821, company_366, company_2043692, company_22749, company_2265503, company_2266833, company_2265988, company_2264658, company_1999063, company_2270094, company_20568, company_2257469, company_1555330, company_1746010, company_2260633, company_2258314, company_2022764, company_2260630, company_1906107, company_1382865, company_1566462, company_1877507, company_2266842, company_1918560, company_2265516, company_1810867, company_1857963, company_1773243, company_300, company_2265085, company_2268596, company_2267266, company_1966162, company_2268116, company_2271768, company_2215251, company_2270438, company_2269446, company_1819688, company_2110642, company_2270430, company_2270431, company_1720715, company_1494320, company_2252671, company_1389474, company_1939457, company_2263328, company_2253528, company_2265096, company_1915028, company_2156861, company_2268128, company_2269457, company_2271777, company_1942629, company_1530874, company_1754504, company_2267280, company_321, company_1918980, company_322, company_2253514, company_1542863, company_2262465, company_1724296, company_2267288, company_2271788, company_2270451, company_317, company_2228564, company_314, company_313, company_2263305, company_2268142, company_2269471, company_318, company_1822886, company_1981338, company_2269479, company_2270465, company_2271313, company_2271796, company_1863396, company_1479129, company_2184906, company_2252644, company_1552694, company_2260269, company_2269481, company_1948380, company_2268156, company_1446283, company_2269485, company_2271327, company_2259272, company_2270473, company_2030322, company_1343679, company_2269495, company_2260253, company_2263762, company_1472509, company_2239673, company_2269016, company_3528, company_2271334, company_2270489, company_2270006, company_1796336, company_2142266, company_2257089, company_2242837, company_2270482, company_2205434, company_1586445, company_2268170, company_2253955, company_2268177, company_1867789, company_2271347, company_5715, company_2270011, company_2270496, company_5712, company_2259252, company_1668576, company_2238328, company_826081, company_1729532, company_2269030, company_1983551, company_2251769, company_1914117, company_2269038, company_1564682, company_2270027, company_2265911, company_5723, company_2240639, company_77482, company_2265918, company_2270020, company_1993026, company_41, company_1707699, company_2263059, company_2264392, company_2271915, company_1228645, company_2229140, company_2267420, company_2271922, company_2263052, company_2265244, company_2266574, company_1891004, company_2268753, company_2069384, company_2244783, company_2267427, company_1548781, company_1499295, company_2269607, company_8222, company_810, company_2263046, company_2267430, company_1872712, company_2051630, company_2270601, company_1792735, company_2266587, company_2268764, company_2267437, company_2269614, company_2271931, company_1750098, company_41857, company_1957391, company_2271936, company_2266594, company_2270613, company_2268774, company_194466, company_2271945, company_1894536, company_2266119, company_2267449, company_2268779, company_2269626, company_1962788, company_1720659, company_1603021, company_1551504, company_2032075, company_2130795, company_152601, company_2265271, company_2263024, company_2262173, company_1868685, company_2268788, company_2269635, company_2265279, company_2271956, company_2266128, company_2267458, company_2268305, company_2071246, company_1514501, company_1838840, company_2121856, company_2268310, company_2270627, company_2268793, company_148986, company_2263493, company_2265288, company_2268312, company_2267469, company_2268319, company_1549674, company_2269647, company_2271963, company_8262, company_1958693, company_2222957, company_1883892, company_111237, company_2209963, company_2266140, company_1761174, company_1764206, company_2267477, company_2271977, company_2262150, company_2265299, company_2268326, company_417069, company_1492611, company_2266149, company_2270643, company_1662640, company_2255850, company_1497097, company_2254522, company_1882547, company_2269661, company_2124906, company_2268331, company_2266156, company_2271984, company_2267007, company_2268338, company_2270655, company_2140152, company_114728, company_2267491, company_2268340, company_1794093, company_2049309, company_2131684, company_2269674, company_2267497, company_2271515, company_2266167, company_2270668, company_2271994, company_1892327, company_2058247, company_1552861, company_1946203, company_2271081, company_2271082, company_1677314, company_1998796, company_2251909, company_2267822, company_2265645, company_2271089, company_2257691, company_2267827, company_1398748, company_2056483, company_2266982, company_2267833, company_1736604, company_2266506, company_1791485, company_2264329, company_2066281, company_2271096, company_2257683, company_1498388, company_2169370, company_1470810, company_2245693, company_2235409, company_2247879, company_2267840, company_2265664, company_1467644, company_2266518, company_2255495, company_1948838, company_1575080, company_1897651, company_1298581, company_1984160, company_2264341, company_2267850, company_2108400, company_2268702, company_2258993, company_2259840, company_2258510, company_2123187, company_2255485, company_1641321, company_54710, company_1643988, company_1411619, company_2259832, company_1863886, company_2258986, company_2265680, company_17764, company_2266531, company_1502118, company_2265202, company_2265687, company_1955585, company_2267868, company_1457853, company_1883493, company_2260819, company_852817, company_2253287, company_1599096, company_1537620, company_1852763, company_2211400, company_2265694, company_1522187, company_2052087, company_2247844, company_2266548, company_2268723, company_1770967, company_2258972, company_2246519, company_1882156, company_112138, company_1759718, company_1910660, company_262242, company_1744227, company_1891060, company_2025744, company_1653766, company_1970801, company_1893244, company_2267400, company_2268732, company_2245657, company_1815347, company_2251090, company_2267407, company_814553, company_1987232, company_810196, company_2256774, company_2271907, company_1913704, company_2265230, company_2266562, company_2267892, company_2264385, company_2268744, company_2221697, company_2011117, company_8674, company_104173, company_1671616, company_1805562, company_1280781, company_1940171, company_2210089, company_2269164, company_11983, company_87163, company_87166, company_2181560, company_1487759, company_2264711, company_2270151, company_1692565, company_2271490, company_2261667, company_404246, company_2123205, company_2263843, company_11992, company_2262990, company_87176, company_1676059, company_1956983, company_2271497, company_2270160, company_2264728, company_1683614, company_2262509, company_490, company_1970726, company_1827373, company_2266909, company_1919557, company_862241, company_1451774, company_1691242, company_2260322, company_2261652, company_1873235, company_1401070, company_2077358, company_1645780, company_1864754, company_2266912, company_18151, company_1528291, company_2206844, company_2270171, company_2264739, company_2263829, company_20472, company_2003095, company_2161938, company_2193996, company_1763734, company_1819755, company_1652084, company_2246017, company_2264747, company_2257145, company_1885201, company_2270185, company_2153, company_2195763, company_2150, company_1838049, company_2074261, company_2266931, company_2265600, company_2227723, company_1052820, company_1976040, company_2257130, company_2271047, company_1497513, company_1683642, company_2271046, company_978787, company_2145, company_2270193, company_2271040, company_1756146, company_457, company_2261625, company_1729833, company_2266944, company_1465931, company_2265614, company_2271056, company_2259301, company_2157, company_2271054, company_2271053, company_5663, company_1994736, company_397831, company_2257119, company_2260763, company_2261610, company_487, company_1613712, company_1716508, company_55508, company_2266951, company_1733084, company_2264777, company_2265624, company_1591523, company_2257592, company_1711290, company_2271068, company_2271063, company_2145048, company_1430402, company_2260750, company_2246451, company_466405, company_2224205, company_2247305, company_2266966, company_2267812, company_2254072, company_2265636, company_2264308, company_2256255, company_2267819, company_2271075, company_1447693, company_1392538, company_1540301, company_1542968, company_2267386, company_2270557, company_2269569, company_2008713, company_2268235, company_2271406, company_2271886, company_1979112, company_2164143, company_1456165, company_1993418, company_1808684, company_1489089, company_2263445, company_2267393, company_2266069, company_2269579, company_2268249, company_2271418, company_1817154, company_2271894, company_2258096, company_445, company_1970325, company_2190898, company_2263431, company_2269100, company_2269108, company_1627516, company_1985823, company_1835836, company_2206449, company_2270570, company_1635594, company_2269590, company_1583025, company_2263424, company_2262576, company_2252779, company_2269597, company_818151, company_2266086, company_2260393, company_2268268, company_2270108, company_2270102, company_1518023, company_1985811, company_2270584, company_2271431, company_2168974, company_1994799, company_2263895, company_2266098, company_2268275, company_2269122, company_2063523, company_2216662, company_2270115, company_1759250, company_2271446, company_22200, company_2270592, company_1450894, company_855, company_1347911, company_2263886, company_1890696, company_2262551, company_2268288, company_2216651, company_2270129, company_2271459, company_2026188, company_1564780, company_19032, company_2258054, company_1408908, company_2269142, company_2268296, company_1450405, company_1656487, company_1725068, company_2002198, company_2112526, company_2257193, company_2270137, company_2247380, company_56444, company_1426783, company_1880874, company_2263867, company_2269152, company_1467296, company_2263860, company_2261680, company_1856780, company_1902266, company_2269159, company_2270144, company_2271476, company_2264704, company_432263] [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:53,402 INFO MySQL|company_db_1019|snapshot Step 5: read binlog position of MySQL master [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:53,405 INFO MySQL|company_db_1019|snapshot using binlog 'mysql-bin.000072' at position '1062474967' and gtid '36e81c0e-42d6-11e8-9953-fa163e31dda3:1-2729343, 4ca60776-d4fd-11e7-b7bd-fa163e5997e8:1-20106, 6163e17a-efe4-11e7-bb8e-fa163e31dda3:1-29265177, be401594-f975-11e7-9367-fa163e5997e8:1-29609199' [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:49:53,405 INFO MySQL|company_db_1019|snapshot Step 6: generating DROP and CREATE statements to reflect current database schemas: [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:50:41,275 INFO || WorkerSourceTask{id=company_db_1019-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:50:41,275 INFO || WorkerSourceTask{id=company_db_1019-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:51:41,276 INFO || WorkerSourceTask{id=company_db_1019-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:51:41,277 INFO || WorkerSourceTask{id=company_db_1019-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:52:41,277 INFO || WorkerSourceTask{id=company_db_1019-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:52:41,278 INFO || WorkerSourceTask{id=company_db_1019-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:52:56,306 INFO MySQL|company_db_1019|snapshot Step 7: rolling back transaction after abort [io.debezium.connector.mysql.SnapshotReader] 2018-05-07 08:52:56,308 ERROR MySQL|company_db_1019|snapshot Failed due to error: Aborting snapshot due to error when last running 'ROLLBACK': No operations allowed after connection closed. [io.debezium.connector.mysql.SnapshotReader] org.apache.kafka.connect.errors.ConnectException: No operations allowed after connection closed. Error code: 0; SQLSTATE: 08003. at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:200) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:178) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:670) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: No operations allowed after connection closed. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:918) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:897) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:886) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:860) at com.mysql.jdbc.ConnectionImpl.throwConnectionClosedException(ConnectionImpl.java:1246) at com.mysql.jdbc.ConnectionImpl.checkClosed(ConnectionImpl.java:1241) at com.mysql.jdbc.ConnectionImpl.createStatement(ConnectionImpl.java:2436) at com.mysql.jdbc.ConnectionImpl.createStatement(ConnectionImpl.java:2420) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:309) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:287) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:609) ... 3 more Caused by: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure The last packet successfully received from the server was 182,900 milliseconds ago. The last packet sent successfully to the server was 3 milliseconds ago. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:989) at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3556) at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3456) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3897) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2524) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2677) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2545) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2503) at com.mysql.jdbc.StatementImpl.executeQuery(StatementImpl.java:1369) at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:390) at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:347) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:417) ... 3 more Caused by: java.io.EOFException: Can not read response from server. Expected to read 4 bytes, read 0 bytes before connection was unexpectedly lost. at com.mysql.jdbc.MysqlIO.readFully(MysqlIO.java:3008) at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3466) ... 13 more 2018-05-07 08:52:56,932 INFO || WorkerSourceTask{id=company_db_1019-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:52:56,934 INFO || WorkerSourceTask{id=company_db_1019-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:52:56,934 ERROR || WorkerSourceTask{id=company_db_1019-0} Task threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException: No operations allowed after connection closed. Error code: 0; SQLSTATE: 08003. at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:200) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:178) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:670) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: No operations allowed after connection closed. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:918) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:897) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:886) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:860) at com.mysql.jdbc.ConnectionImpl.throwConnectionClosedException(ConnectionImpl.java:1246) at com.mysql.jdbc.ConnectionImpl.checkClosed(ConnectionImpl.java:1241) at com.mysql.jdbc.ConnectionImpl.createStatement(ConnectionImpl.java:2436) at com.mysql.jdbc.ConnectionImpl.createStatement(ConnectionImpl.java:2420) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:309) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:287) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:609) ... 3 more Caused by: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure The last packet successfully received from the server was 182,900 milliseconds ago. The last packet sent successfully to the server was 3 milliseconds ago. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:989) at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3556) at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3456) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3897) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2524) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2677) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2545) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2503) at com.mysql.jdbc.StatementImpl.executeQuery(StatementImpl.java:1369) at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:390) at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:347) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:417) ... 3 more Caused by: java.io.EOFException: Can not read response from server. Expected to read 4 bytes, read 0 bytes before connection was unexpectedly lost. at com.mysql.jdbc.MysqlIO.readFully(MysqlIO.java:3008) at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3466) ... 13 more 2018-05-07 08:52:56,934 ERROR || WorkerSourceTask{id=company_db_1019-0} Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask] 2018-05-07 08:52:56,934 INFO || [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2018-05-07 08:53:41,279 INFO || WorkerSourceTask{id=company_db_1019-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:53:41,280 INFO || WorkerSourceTask{id=company_db_1019-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:54:41,280 INFO || WorkerSourceTask{id=company_db_1019-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2018-05-07 08:54:41,280 INFO || WorkerSourceTask{id=company_db_1019-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]