Attaching to docker-compose_connect-debezium_1_7f42f918637d connect-debezium_1_7f42f918637d | Plugins are loaded from /kafka/connect connect-debezium_1_7f42f918637d | Plugins are loaded from /kafka/connect connect-debezium_1_7f42f918637d | Using the following environment variables: connect-debezium_1_7f42f918637d | GROUP_ID=1 connect-debezium_1_7f42f918637d | CONFIG_STORAGE_TOPIC=my_connect_configs connect-debezium_1_7f42f918637d | OFFSET_STORAGE_TOPIC=my_connect_offsets connect-debezium_1_7f42f918637d | BOOTSTRAP_SERVERS=kafka:29092 connect-debezium_1_7f42f918637d | REST_HOST_NAME=172.23.0.11 connect-debezium_1_7f42f918637d | REST_PORT=8083 connect-debezium_1_7f42f918637d | ADVERTISED_HOST_NAME=172.23.0.11 connect-debezium_1_7f42f918637d | ADVERTISED_PORT=8083 connect-debezium_1_7f42f918637d | KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | INTERNAL_KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | INTERNAL_VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | OFFSET_FLUSH_INTERVAL_MS=60000 connect-debezium_1_7f42f918637d | OFFSET_FLUSH_TIMEOUT_MS= connect-debezium_1_7f42f918637d | SHUTDOWN_TIMEOUT=10000 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_INTERNAL_VALUE_CONVERTER: internal.value.converter=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_VALUE_CONVERTER: value.converter=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_REST_ADVERTISED_HOST_NAME: rest.advertised.host.name=172.23.0.11 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_OFFSET_FLUSH_INTERVAL_MS: offset.flush.interval.ms=60000 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL: key.converter.schema.registry.url=http://schema-registry:8081 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_GROUP_ID: group.id=1 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_BOOTSTRAP_SERVERS: bootstrap.servers=kafka:29092 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_KEY_CONVERTER: key.converter=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_TASK_SHUTDOWN_GRACEFUL_TIMEOUT_MS: task.shutdown.graceful.timeout.ms=10000 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_REST_HOST_NAME: rest.host.name=172.23.0.11 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_PLUGIN_PATH: plugin.path=/kafka/connect connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_REST_PORT: rest.port=8083 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_OFFSET_FLUSH_TIMEOUT_MS: offset.flush.timeout.ms=5000 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: value.converter.schema.registry.url=http://schema-registry:8081 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_INTERNAL_KEY_CONVERTER: internal.key.converter=org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_CONFIG_STORAGE_TOPIC: config.storage.topic=my_connect_configs connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_REST_ADVERTISED_PORT: rest.advertised.port=8083 connect-debezium_1_7f42f918637d | --- Setting property from CONNECT_OFFSET_STORAGE_TOPIC: offset.storage.topic=my_connect_offsets connect-debezium_1_7f42f918637d | 2018-12-04 10:54:51,018 INFO || Kafka Connect distributed worker initializing ... [org.apache.kafka.connect.cli.ConnectDistributed] connect-debezium_1_7f42f918637d | 2018-12-04 10:54:51,110 INFO || WorkerInfo values: connect-debezium_1_7f42f918637d | jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -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 connect-debezium_1_7f42f918637d | jvm.spec = Oracle Corporation, OpenJDK 64-Bit Server VM, 1.8.0_181, 25.181-b13 connect-debezium_1_7f42f918637d | jvm.classpath = /kafka/bin/../libs/activation-1.1.1.jar:/kafka/bin/../libs/aopalliance-repackaged-2.5.0-b42.jar:/kafka/bin/../libs/argparse4j-0.7.0.jar:/kafka/bin/../libs/audience-annotations-0.5.0.jar:/kafka/bin/../libs/avro-1.8.2.jar:/kafka/bin/../libs/common-config-5.0.0.jar:/kafka/bin/../libs/common-utils-5.0.0.jar:/kafka/bin/../libs/commons-lang3-3.5.jar:/kafka/bin/../libs/connect-api-2.0.0.jar:/kafka/bin/../libs/connect-basic-auth-extension-2.0.0.jar:/kafka/bin/../libs/connect-file-2.0.0.jar:/kafka/bin/../libs/connect-json-2.0.0.jar:/kafka/bin/../libs/connect-runtime-2.0.0.jar:/kafka/bin/../libs/connect-transforms-2.0.0.jar:/kafka/bin/../libs/guava-20.0.jar:/kafka/bin/../libs/hk2-api-2.5.0-b42.jar:/kafka/bin/../libs/hk2-locator-2.5.0-b42.jar:/kafka/bin/../libs/hk2-utils-2.5.0-b42.jar:/kafka/bin/../libs/instant_client:/kafka/bin/../libs/jackson-annotations-2.9.6.jar:/kafka/bin/../libs/jackson-core-2.9.6.jar:/kafka/bin/../libs/jackson-core-asl-1.9.13.jar:/kafka/bin/../libs/jackson-databind-2.9.6.jar:/kafka/bin/../libs/jackson-jaxrs-base-2.9.6.jar:/kafka/bin/../libs/jackson-jaxrs-json-provider-2.9.6.jar:/kafka/bin/../libs/jackson-mapper-asl-1.9.13.jar:/kafka/bin/../libs/jackson-module-jaxb-annotations-2.9.6.jar:/kafka/bin/../libs/javassist-3.22.0-CR2.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-b42.jar:/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/kafka/bin/../libs/javax.ws.rs-api-2.1.jar:/kafka/bin/../libs/jaxb-api-2.3.0.jar:/kafka/bin/../libs/jersey-client-2.27.jar:/kafka/bin/../libs/jersey-common-2.27.jar:/kafka/bin/../libs/jersey-container-servlet-2.27.jar:/kafka/bin/../libs/jersey-container-servlet-core-2.27.jar:/kafka/bin/../libs/jersey-hk2-2.27.jar:/kafka/bin/../libs/jersey-media-jaxb-2.27.jar:/kafka/bin/../libs/jersey-server-2.27.jar:/kafka/bin/../libs/jetty-client-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-continuation-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-http-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-io-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-security-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-server-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-servlet-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-servlets-9.4.11.v20180605.jar:/kafka/bin/../libs/jetty-util-9.4.11.v20180605.jar:/kafka/bin/../libs/jopt-simple-5.0.4.jar:/kafka/bin/../libs/kafka-avro-serializer-5.0.0.jar:/kafka/bin/../libs/kafka-clients-2.0.0.jar:/kafka/bin/../libs/kafka-connect-avro-converter-5.0.0.jar:/kafka/bin/../libs/kafka-log4j-appender-2.0.0.jar:/kafka/bin/../libs/kafka-schema-registry-client-5.0.0.jar:/kafka/bin/../libs/kafka-streams-2.0.0.jar:/kafka/bin/../libs/kafka-streams-examples-2.0.0.jar:/kafka/bin/../libs/kafka-streams-scala_2.11-2.0.0.jar:/kafka/bin/../libs/kafka-streams-test-utils-2.0.0.jar:/kafka/bin/../libs/kafka-tools-2.0.0.jar:/kafka/bin/../libs/kafka_2.11-2.0.0.jar:/kafka/bin/../libs/log4j-1.2.17.jar:/kafka/bin/../libs/lz4-java-1.4.1.jar:/kafka/bin/../libs/maven-artifact-3.5.3.jar:/kafka/bin/../libs/metrics-core-2.2.0.jar:/kafka/bin/../libs/ojdbc8.jar:/kafka/bin/../libs/osgi-resource-locator-1.0.1.jar:/kafka/bin/../libs/plexus-utils-3.1.0.jar:/kafka/bin/../libs/reflections-0.9.11.jar:/kafka/bin/../libs/rocksdbjni-5.7.3.jar:/kafka/bin/../libs/scala-library-2.11.12.jar:/kafka/bin/../libs/scala-logging_2.11-3.9.0.jar:/kafka/bin/../libs/scala-reflect-2.11.12.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.7.1.jar:/kafka/bin/../libs/validation-api-1.1.0.Final.jar:/kafka/bin/../libs/xstreams.jar:/kafka/bin/../libs/zkclient-0.10.jar:/kafka/bin/../libs/zookeeper-3.4.13.jar connect-debezium_1_7f42f918637d | os.spec = Linux, amd64, 4.9.125-linuxkit connect-debezium_1_7f42f918637d | os.vcpus = 4 connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.WorkerInfo] connect-debezium_1_7f42f918637d | 2018-12-04 10:54:51,116 INFO || Scanning for plugin classes. This might take a moment ... [org.apache.kafka.connect.cli.ConnectDistributed] connect-debezium_1_7f42f918637d | 2018-12-04 10:54:51,510 INFO || Loading plugin from: /kafka/connect/debezium-connector-sqlserver [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,080 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,094 INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,095 INFO || Added plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,095 INFO || Added plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,097 INFO || Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,107 INFO || Added plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,108 INFO || Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:05,108 INFO || Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:06,345 INFO || Loading plugin from: /kafka/connect/debezium-connector-oracle [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:09,333 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:09,333 INFO || Added plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:09,349 INFO || Loading plugin from: /kafka/connect/debezium-connector-mongodb [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:12,235 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:12,236 INFO || Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:12,251 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:12,382 INFO || Loading plugin from: /kafka/connect/debezium-connector-postgres [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:14,445 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:14,446 INFO || Added plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:14,575 INFO || Loading plugin from: /kafka/connect/debezium-connector-mysql [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:19,114 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:19,126 INFO || Added plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,144 INFO || Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,166 INFO || Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,166 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,167 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,167 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,167 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,168 INFO || Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,168 INFO || Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,181 INFO || Added plugin 'org.apache.kafka.connect.tools.MockConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,181 INFO || Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,182 INFO || Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,182 INFO || Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,194 INFO || Added plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,194 INFO || Added plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,194 INFO || Added plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,206 INFO || Added plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,207 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,207 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,212 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,232 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,232 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,233 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,233 INFO || Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,233 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,233 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,237 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,246 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,247 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,249 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,249 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,258 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,259 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,261 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,262 INFO || Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,263 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,264 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,264 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,265 INFO || Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,289 INFO || Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,332 INFO || Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,358 INFO || Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,359 INFO || Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,372 INFO || Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,373 INFO || Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,374 INFO || Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,375 INFO || Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,376 INFO || Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,385 INFO || Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,388 INFO || Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,417 INFO || Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,418 INFO || Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,418 INFO || Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,419 INFO || Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,419 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,420 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,421 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,424 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,432 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,445 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,447 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,448 INFO || Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,455 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,467 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,470 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,471 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,472 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,474 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,482 INFO || Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,483 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,485 INFO || Added alias 'UnwrapFromMongoDbEnvelope' to plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,486 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,515 INFO || Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,525 INFO || Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,539 INFO || Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,540 INFO || Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,540 INFO || Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,959 INFO || DistributedConfig values: connect-debezium_1_7f42f918637d | access.control.allow.methods = connect-debezium_1_7f42f918637d | access.control.allow.origin = connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | config.providers = [] connect-debezium_1_7f42f918637d | config.storage.replication.factor = 1 connect-debezium_1_7f42f918637d | config.storage.topic = my_connect_configs connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | group.id = 1 connect-debezium_1_7f42f918637d | header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter connect-debezium_1_7f42f918637d | heartbeat.interval.ms = 3000 connect-debezium_1_7f42f918637d | internal.key.converter = class org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | internal.value.converter = class org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | key.converter = class org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | listeners = null connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | offset.flush.interval.ms = 60000 connect-debezium_1_7f42f918637d | offset.flush.timeout.ms = 5000 connect-debezium_1_7f42f918637d | offset.storage.partitions = 25 connect-debezium_1_7f42f918637d | offset.storage.replication.factor = 1 connect-debezium_1_7f42f918637d | offset.storage.topic = my_connect_offsets connect-debezium_1_7f42f918637d | plugin.path = [/kafka/connect] connect-debezium_1_7f42f918637d | rebalance.timeout.ms = 60000 connect-debezium_1_7f42f918637d | receive.buffer.bytes = 32768 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 40000 connect-debezium_1_7f42f918637d | rest.advertised.host.name = 172.23.0.11 connect-debezium_1_7f42f918637d | rest.advertised.listener = null connect-debezium_1_7f42f918637d | rest.advertised.port = 8083 connect-debezium_1_7f42f918637d | rest.extension.classes = [] connect-debezium_1_7f42f918637d | rest.host.name = 172.23.0.11 connect-debezium_1_7f42f918637d | rest.port = 8083 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | session.timeout.ms = 10000 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.client.auth = none connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | status.storage.partitions = 5 connect-debezium_1_7f42f918637d | status.storage.replication.factor = 1 connect-debezium_1_7f42f918637d | status.storage.topic = connect-status connect-debezium_1_7f42f918637d | task.shutdown.graceful.timeout.ms = 10000 connect-debezium_1_7f42f918637d | value.converter = class org.apache.kafka.connect.json.JsonConverter connect-debezium_1_7f42f918637d | worker.sync.timeout.ms = 3000 connect-debezium_1_7f42f918637d | worker.unsync.backoff.ms = 300000 connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.distributed.DistributedConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,973 INFO || Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value matches the default, so this property can be safely removed from the worker configuration. [org.apache.kafka.connect.runtime.WorkerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:37,983 INFO || Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value matches the default, so this property can be safely removed from the worker configuration. [org.apache.kafka.connect.runtime.WorkerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:38,049 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:39,288 INFO || AdminClientConfig values: connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | connections.max.idle.ms = 300000 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | receive.buffer.bytes = 65536 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 120000 connect-debezium_1_7f42f918637d | retries = 5 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,279 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,279 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,303 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,303 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,304 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,304 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,305 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,305 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,305 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,306 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,306 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,307 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,308 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,308 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,310 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,313 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,315 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,328 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,329 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,330 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,330 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,331 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,331 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,352 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:41,353 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:43,397 INFO || Kafka cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.connect.util.ConnectUtils] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:43,593 INFO || Logging initialized @60451ms to org.eclipse.jetty.util.log.Slf4jLog [org.eclipse.jetty.util.log] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:43,963 INFO || Added connector for http://172.23.0.11:8083 [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:44,172 INFO || Advertised URI: http://172.23.0.11:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:44,282 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:44,288 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,359 INFO || JsonConverterConfig values: connect-debezium_1_7f42f918637d | converter.type = key connect-debezium_1_7f42f918637d | schemas.cache.size = 1000 connect-debezium_1_7f42f918637d | schemas.enable = false connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.json.JsonConverterConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,377 INFO || JsonConverterConfig values: connect-debezium_1_7f42f918637d | converter.type = value connect-debezium_1_7f42f918637d | schemas.cache.size = 1000 connect-debezium_1_7f42f918637d | schemas.enable = false connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.json.JsonConverterConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,730 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,730 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,751 INFO || Kafka Connect distributed worker initialization took 54787ms [org.apache.kafka.connect.cli.ConnectDistributed] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,751 INFO || Kafka Connect starting [org.apache.kafka.connect.runtime.Connect] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,752 INFO || Starting REST server [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,774 INFO || Herder starting [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,794 INFO || Worker starting [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,794 INFO || Starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,795 INFO || Starting KafkaBasedLog with topic my_connect_offsets [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,795 INFO || AdminClientConfig values: connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | connections.max.idle.ms = 300000 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | receive.buffer.bytes = 65536 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 120000 connect-debezium_1_7f42f918637d | retries = 5 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,809 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,809 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,810 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,810 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,810 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,810 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,810 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,810 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,811 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,811 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,811 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,811 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,811 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,811 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,812 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,812 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,812 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,812 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,812 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,853 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,853 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,853 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,853 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,864 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:45,872 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:46,997 INFO || jetty-9.4.11.v20180605; built: 2018-06-05T18:24:03.829Z; git: d5fc0523cfa96bfebfbda19606cad384d772f04c; jvm 1.8.0_181-b13 [org.eclipse.jetty.server.Server] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:47,474 INFO || DefaultSessionIdManager workerName=node0 [org.eclipse.jetty.server.session] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:47,474 INFO || No SessionScavenger set, using defaults [org.eclipse.jetty.server.session] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:47,498 INFO || node0 Scavenging every 600000ms [org.eclipse.jetty.server.session] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:53,485 INFO || Created topic (name=my_connect_offsets, numPartitions=25, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka:29092 [org.apache.kafka.connect.util.TopicAdmin] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:53,720 INFO || ProducerConfig values: connect-debezium_1_7f42f918637d | acks = all connect-debezium_1_7f42f918637d | batch.size = 16384 connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | buffer.memory = 33554432 connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | compression.type = none connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | enable.idempotence = false connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer connect-debezium_1_7f42f918637d | linger.ms = 0 connect-debezium_1_7f42f918637d | max.block.ms = 60000 connect-debezium_1_7f42f918637d | max.in.flight.requests.per.connection = 1 connect-debezium_1_7f42f918637d | max.request.size = 1048576 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner connect-debezium_1_7f42f918637d | receive.buffer.bytes = 32768 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 30000 connect-debezium_1_7f42f918637d | retries = 2147483647 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | transaction.timeout.ms = 60000 connect-debezium_1_7f42f918637d | transactional.id = null connect-debezium_1_7f42f918637d | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,237 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,237 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,238 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,238 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,240 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,240 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,240 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,242 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,242 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,243 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,249 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,249 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,249 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,253 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,258 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,258 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,258 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,259 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,261 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,261 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,262 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,262 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,262 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,263 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,263 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,388 INFO || ConsumerConfig values: connect-debezium_1_7f42f918637d | auto.commit.interval.ms = 5000 connect-debezium_1_7f42f918637d | auto.offset.reset = earliest connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | check.crcs = true connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | default.api.timeout.ms = 60000 connect-debezium_1_7f42f918637d | enable.auto.commit = false connect-debezium_1_7f42f918637d | exclude.internal.topics = true connect-debezium_1_7f42f918637d | fetch.max.bytes = 52428800 connect-debezium_1_7f42f918637d | fetch.max.wait.ms = 500 connect-debezium_1_7f42f918637d | fetch.min.bytes = 1 connect-debezium_1_7f42f918637d | group.id = 1 connect-debezium_1_7f42f918637d | heartbeat.interval.ms = 3000 connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | internal.leave.group.on.close = true connect-debezium_1_7f42f918637d | isolation.level = read_uncommitted connect-debezium_1_7f42f918637d | key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer connect-debezium_1_7f42f918637d | max.partition.fetch.bytes = 1048576 connect-debezium_1_7f42f918637d | max.poll.interval.ms = 300000 connect-debezium_1_7f42f918637d | max.poll.records = 500 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] connect-debezium_1_7f42f918637d | receive.buffer.bytes = 65536 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 30000 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | session.timeout.ms = 10000 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,898 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,899 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,899 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,899 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,899 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,899 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,899 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,899 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,900 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,901 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,901 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,901 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,901 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:54,901 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:55,005 INFO || Cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.clients.Metadata] connect-debezium_1_7f42f918637d | Dec 04, 2018 10:55:55 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime connect-debezium_1_7f42f918637d | WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. connect-debezium_1_7f42f918637d | Dec 04, 2018 10:55:55 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime connect-debezium_1_7f42f918637d | WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. connect-debezium_1_7f42f918637d | Dec 04, 2018 10:55:55 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime connect-debezium_1_7f42f918637d | WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. connect-debezium_1_7f42f918637d | Dec 04, 2018 10:55:57 AM org.glassfish.jersey.internal.Errors logErrors connect-debezium_1_7f42f918637d | WARNING: The following warnings have been detected: WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. connect-debezium_1_7f42f918637d | WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. connect-debezium_1_7f42f918637d | WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. connect-debezium_1_7f42f918637d | WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. connect-debezium_1_7f42f918637d | connect-debezium_1_7f42f918637d | 2018-12-04 10:55:57,874 INFO || Started o.e.j.s.ServletContextHandler@205bed61{/,null,AVAILABLE} [org.eclipse.jetty.server.handler.ContextHandler] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:57,923 INFO || Started http_172.23.0.118083@165e389b{HTTP/1.1,[http/1.1]}{172.23.0.11:8083} [org.eclipse.jetty.server.AbstractConnector] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:57,960 INFO || Started @74816ms [org.eclipse.jetty.server.Server] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:57,961 INFO || Advertised URI: http://172.23.0.11:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:57,969 INFO || REST server listening at http://172.23.0.11:8083/, advertising URL http://172.23.0.11:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 10:55:57,969 INFO || Kafka Connect started [org.apache.kafka.connect.runtime.Connect] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,349 INFO || [Consumer clientId=consumer-1, groupId=1] Discovered group coordinator kafka:29092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,809 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-2 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,810 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-4 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,810 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-6 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,810 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-8 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,810 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-0 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,810 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-18 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,810 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-20 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,810 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-22 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,811 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-24 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,811 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-10 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,811 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-12 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,811 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-14 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,811 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-16 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,811 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-3 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,812 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-5 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,813 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-7 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,813 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-9 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,814 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-1 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,814 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-19 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,814 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-21 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,814 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-23 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,814 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-11 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,814 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-13 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,815 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-15 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,815 INFO || [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition my_connect_offsets-17 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,823 INFO || Finished reading KafkaBasedLog for topic my_connect_offsets [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,824 INFO || Started KafkaBasedLog for topic my_connect_offsets [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,824 INFO || Finished reading offsets topic and starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,827 INFO || Worker started [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,846 INFO || Starting KafkaBasedLog with topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,846 INFO || AdminClientConfig values: connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | connections.max.idle.ms = 300000 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | receive.buffer.bytes = 65536 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 120000 connect-debezium_1_7f42f918637d | retries = 5 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,871 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,872 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,873 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,874 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,874 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,874 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,874 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,874 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:05,874 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,282 INFO || Created topic (name=connect-status, numPartitions=5, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka:29092 [org.apache.kafka.connect.util.TopicAdmin] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,340 INFO || ProducerConfig values: connect-debezium_1_7f42f918637d | acks = all connect-debezium_1_7f42f918637d | batch.size = 16384 connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | buffer.memory = 33554432 connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | compression.type = none connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | enable.idempotence = false connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | key.serializer = class org.apache.kafka.common.serialization.StringSerializer connect-debezium_1_7f42f918637d | linger.ms = 0 connect-debezium_1_7f42f918637d | max.block.ms = 60000 connect-debezium_1_7f42f918637d | max.in.flight.requests.per.connection = 1 connect-debezium_1_7f42f918637d | max.request.size = 1048576 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner connect-debezium_1_7f42f918637d | receive.buffer.bytes = 32768 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 30000 connect-debezium_1_7f42f918637d | retries = 0 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | transaction.timeout.ms = 60000 connect-debezium_1_7f42f918637d | transactional.id = null connect-debezium_1_7f42f918637d | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,392 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,392 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,393 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,399 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,400 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,400 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,400 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,400 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,400 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,400 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,400 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,401 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,401 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,401 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,401 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,401 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,401 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,401 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,402 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,402 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,402 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,409 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,409 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,409 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,409 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,498 INFO || ConsumerConfig values: connect-debezium_1_7f42f918637d | auto.commit.interval.ms = 5000 connect-debezium_1_7f42f918637d | auto.offset.reset = earliest connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | check.crcs = true connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | default.api.timeout.ms = 60000 connect-debezium_1_7f42f918637d | enable.auto.commit = false connect-debezium_1_7f42f918637d | exclude.internal.topics = true connect-debezium_1_7f42f918637d | fetch.max.bytes = 52428800 connect-debezium_1_7f42f918637d | fetch.max.wait.ms = 500 connect-debezium_1_7f42f918637d | fetch.min.bytes = 1 connect-debezium_1_7f42f918637d | group.id = 1 connect-debezium_1_7f42f918637d | heartbeat.interval.ms = 3000 connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | internal.leave.group.on.close = true connect-debezium_1_7f42f918637d | isolation.level = read_uncommitted connect-debezium_1_7f42f918637d | key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer connect-debezium_1_7f42f918637d | max.partition.fetch.bytes = 1048576 connect-debezium_1_7f42f918637d | max.poll.interval.ms = 300000 connect-debezium_1_7f42f918637d | max.poll.records = 500 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] connect-debezium_1_7f42f918637d | receive.buffer.bytes = 65536 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 30000 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | session.timeout.ms = 10000 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,506 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,506 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,506 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,506 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,507 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,508 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,509 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,519 INFO || Cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.clients.Metadata] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,578 INFO || [Consumer clientId=consumer-2, groupId=1] Discovered group coordinator kafka:29092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,646 INFO || [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect-status-1 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,646 INFO || [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect-status-2 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,647 INFO || [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect-status-0 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,647 INFO || [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect-status-3 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,647 INFO || [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect-status-4 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,647 INFO || Finished reading KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,647 INFO || Started KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,681 INFO || Starting KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,681 INFO || Starting KafkaBasedLog with topic my_connect_configs [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,682 INFO || AdminClientConfig values: connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | connections.max.idle.ms = 300000 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | receive.buffer.bytes = 65536 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 120000 connect-debezium_1_7f42f918637d | retries = 5 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,686 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,687 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,687 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,687 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,687 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,687 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,687 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,687 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,688 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,731 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,740 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,740 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,740 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,741 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,741 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,742 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,742 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,742 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,743 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,744 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,745 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,745 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,746 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,767 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:07,773 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,131 INFO || Created topic (name=my_connect_configs, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka:29092 [org.apache.kafka.connect.util.TopicAdmin] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,139 INFO || ProducerConfig values: connect-debezium_1_7f42f918637d | acks = all connect-debezium_1_7f42f918637d | batch.size = 16384 connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | buffer.memory = 33554432 connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | compression.type = none connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | enable.idempotence = false connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | key.serializer = class org.apache.kafka.common.serialization.StringSerializer connect-debezium_1_7f42f918637d | linger.ms = 0 connect-debezium_1_7f42f918637d | max.block.ms = 60000 connect-debezium_1_7f42f918637d | max.in.flight.requests.per.connection = 1 connect-debezium_1_7f42f918637d | max.request.size = 1048576 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner connect-debezium_1_7f42f918637d | receive.buffer.bytes = 32768 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 30000 connect-debezium_1_7f42f918637d | retries = 2147483647 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | transaction.timeout.ms = 60000 connect-debezium_1_7f42f918637d | transactional.id = null connect-debezium_1_7f42f918637d | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,181 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,183 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,183 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,184 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,184 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,184 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,184 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,185 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,185 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,186 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,186 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,186 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,186 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,187 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,187 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,187 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,188 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,188 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,188 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,188 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,189 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,189 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,189 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,200 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,202 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,206 INFO || ConsumerConfig values: connect-debezium_1_7f42f918637d | auto.commit.interval.ms = 5000 connect-debezium_1_7f42f918637d | auto.offset.reset = earliest connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | check.crcs = true connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | default.api.timeout.ms = 60000 connect-debezium_1_7f42f918637d | enable.auto.commit = false connect-debezium_1_7f42f918637d | exclude.internal.topics = true connect-debezium_1_7f42f918637d | fetch.max.bytes = 52428800 connect-debezium_1_7f42f918637d | fetch.max.wait.ms = 500 connect-debezium_1_7f42f918637d | fetch.min.bytes = 1 connect-debezium_1_7f42f918637d | group.id = 1 connect-debezium_1_7f42f918637d | heartbeat.interval.ms = 3000 connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | internal.leave.group.on.close = true connect-debezium_1_7f42f918637d | isolation.level = read_uncommitted connect-debezium_1_7f42f918637d | key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer connect-debezium_1_7f42f918637d | max.partition.fetch.bytes = 1048576 connect-debezium_1_7f42f918637d | max.poll.interval.ms = 300000 connect-debezium_1_7f42f918637d | max.poll.records = 500 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] connect-debezium_1_7f42f918637d | receive.buffer.bytes = 65536 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 30000 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | session.timeout.ms = 10000 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,233 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,241 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,241 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,242 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,242 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,243 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,243 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,244 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,245 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,246 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,247 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,255 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,256 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,256 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,258 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,258 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,258 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,259 WARN || The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,259 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,260 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,262 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,262 WARN || The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,263 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,264 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,380 INFO || Cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.clients.Metadata] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,566 INFO || [Consumer clientId=consumer-3, groupId=1] Discovered group coordinator kafka:29092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,609 INFO || [Consumer clientId=consumer-3, groupId=1] Resetting offset for partition my_connect_configs-0 to offset 0. [org.apache.kafka.clients.consumer.internals.Fetcher] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,610 INFO || Finished reading KafkaBasedLog for topic my_connect_configs [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,611 INFO || Started KafkaBasedLog for topic my_connect_configs [org.apache.kafka.connect.util.KafkaBasedLog] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,612 INFO || Started KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,623 INFO || Herder started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,830 INFO || Cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.clients.Metadata] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,833 INFO || [Worker clientId=connect-1, groupId=1] Discovered group coordinator kafka:29092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:08,862 INFO || [Worker clientId=connect-1, groupId=1] (Re-)joining group [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:09,462 INFO || [Worker clientId=connect-1, groupId=1] Successfully joined group with generation 1 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:09,465 INFO || Joined group and got assignment: Assignment{error=0, leader='connect-1-fb338884-0409-4a18-87d7-442f372c7b52', leaderUrl='http://172.23.0.11:8083/', offset=-1, connectorIds=[], taskIds=[]} [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:09,469 INFO || Starting connectors and tasks using config offset -1 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:56:09,470 INFO || Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,379 INFO || Cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.clients.Metadata] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,462 INFO || Connector ora-source-debezium-xstream config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,959 INFO || Rebalance started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,959 INFO || Finished stopping tasks in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,959 INFO || [Worker clientId=connect-1, groupId=1] (Re-)joining group [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,976 INFO || [Worker clientId=connect-1, groupId=1] Successfully joined group with generation 2 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,977 INFO || Joined group and got assignment: Assignment{error=0, leader='connect-1-fb338884-0409-4a18-87d7-442f372c7b52', leaderUrl='http://172.23.0.11:8083/', offset=1, connectorIds=[ora-source-debezium-xstream], taskIds=[]} [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,977 INFO || Starting connectors and tasks using config offset 1 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,980 INFO || Starting connector ora-source-debezium-xstream [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,987 INFO || ConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,989 INFO || EnrichedConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.field = messagesource connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.value = Debezium CDC from Oracle on asgard connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.topic.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | transforms.InsertTopic.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.value = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.topic.field = messagetopic connect-debezium_1_7f42f918637d | transforms.InsertTopic.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:29,989 INFO || Creating connector ora-source-debezium-xstream of type io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:30,008 INFO || Instantiated connector ora-source-debezium-xstream with version 0.9.0.Alpha2 of type class io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:30,026 INFO || Cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.clients.Metadata] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:30,034 INFO || Finished creating connector ora-source-debezium-xstream [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:30,039 INFO || SourceConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.SourceConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:30,042 INFO || EnrichedConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.field = messagesource connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.value = Debezium CDC from Oracle on asgard connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.topic.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | transforms.InsertTopic.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.value = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.topic.field = messagetopic connect-debezium_1_7f42f918637d | transforms.InsertTopic.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:30,112 INFO || 172.23.0.11 - - [04/Dec/2018:10:58:28 +0000] "POST /connectors/ HTTP/1.1" 201 1233 1311 [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:30,991 INFO || Tasks [ora-source-debezium-xstream-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,500 INFO || Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,500 INFO || Rebalance started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,502 INFO || Stopping connector ora-source-debezium-xstream [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,515 INFO || Stopped connector ora-source-debezium-xstream [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,519 INFO || Finished stopping tasks in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,519 INFO || [Worker clientId=connect-1, groupId=1] (Re-)joining group [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,549 INFO || [Worker clientId=connect-1, groupId=1] Successfully joined group with generation 3 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,549 INFO || Joined group and got assignment: Assignment{error=0, leader='connect-1-fb338884-0409-4a18-87d7-442f372c7b52', leaderUrl='http://172.23.0.11:8083/', offset=3, connectorIds=[ora-source-debezium-xstream], taskIds=[ora-source-debezium-xstream-0]} [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,550 INFO || Starting connectors and tasks using config offset 3 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,553 INFO || Starting connector ora-source-debezium-xstream [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,554 INFO || ConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,560 INFO || Starting task ora-source-debezium-xstream-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,561 INFO || Creating task ora-source-debezium-xstream-0 [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,561 INFO || EnrichedConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.field = messagesource connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.value = Debezium CDC from Oracle on asgard connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.topic.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | transforms.InsertTopic.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.value = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.topic.field = messagetopic connect-debezium_1_7f42f918637d | transforms.InsertTopic.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,567 INFO || Creating connector ora-source-debezium-xstream of type io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,567 INFO || Instantiated connector ora-source-debezium-xstream with version 0.9.0.Alpha2 of type class io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,569 INFO || Finished creating connector ora-source-debezium-xstream [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,570 INFO || ConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,570 INFO || SourceConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.SourceConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,574 INFO || EnrichedConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.field = messagesource connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.value = Debezium CDC from Oracle on asgard connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.topic.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | transforms.InsertTopic.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.value = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.topic.field = messagetopic connect-debezium_1_7f42f918637d | transforms.InsertTopic.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,576 INFO || EnrichedConnectorConfig values: connect-debezium_1_7f42f918637d | config.action.reload = RESTART connect-debezium_1_7f42f918637d | connector.class = io.debezium.connector.oracle.OracleConnector connect-debezium_1_7f42f918637d | errors.log.enable = false connect-debezium_1_7f42f918637d | errors.log.include.messages = false connect-debezium_1_7f42f918637d | errors.retry.delay.max.ms = 60000 connect-debezium_1_7f42f918637d | errors.retry.timeout = 0 connect-debezium_1_7f42f918637d | errors.tolerance = none connect-debezium_1_7f42f918637d | header.converter = null connect-debezium_1_7f42f918637d | key.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | name = ora-source-debezium-xstream connect-debezium_1_7f42f918637d | tasks.max = 1 connect-debezium_1_7f42f918637d | transforms = [InsertTopic, InsertSourceDetails] connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.field = messagesource connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.static.value = Debezium CDC from Oracle on asgard connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.topic.field = null connect-debezium_1_7f42f918637d | transforms.InsertSourceDetails.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | transforms.InsertTopic.offset.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.partition.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.static.value = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.timestamp.field = null connect-debezium_1_7f42f918637d | transforms.InsertTopic.topic.field = messagetopic connect-debezium_1_7f42f918637d | transforms.InsertTopic.type = class org.apache.kafka.connect.transforms.InsertField$Value connect-debezium_1_7f42f918637d | value.converter = class io.confluent.connect.avro.AvroConverter connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,597 INFO || TaskConfig values: connect-debezium_1_7f42f918637d | task.class = class io.debezium.connector.oracle.OracleConnectorTask connect-debezium_1_7f42f918637d | [org.apache.kafka.connect.runtime.TaskConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,599 INFO || Instantiated task ora-source-debezium-xstream-0 with version 0.9.0.Alpha2 of type io.debezium.connector.oracle.OracleConnectorTask [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:31,624 INFO || AvroConverterConfig values: connect-debezium_1_7f42f918637d | schema.registry.url = [http://schema-registry:8081] connect-debezium_1_7f42f918637d | basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | auto.register.schemas = true connect-debezium_1_7f42f918637d | max.schemas.per.subject = 1000 connect-debezium_1_7f42f918637d | basic.auth.credentials.source = URL connect-debezium_1_7f42f918637d | schema.registry.basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | [io.confluent.connect.avro.AvroConverterConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,491 INFO || KafkaAvroSerializerConfig values: connect-debezium_1_7f42f918637d | schema.registry.url = [http://schema-registry:8081] connect-debezium_1_7f42f918637d | basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | auto.register.schemas = true connect-debezium_1_7f42f918637d | max.schemas.per.subject = 1000 connect-debezium_1_7f42f918637d | basic.auth.credentials.source = URL connect-debezium_1_7f42f918637d | schema.registry.basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,517 INFO || KafkaAvroDeserializerConfig values: connect-debezium_1_7f42f918637d | schema.registry.url = [http://schema-registry:8081] connect-debezium_1_7f42f918637d | basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | auto.register.schemas = true connect-debezium_1_7f42f918637d | max.schemas.per.subject = 1000 connect-debezium_1_7f42f918637d | basic.auth.credentials.source = URL connect-debezium_1_7f42f918637d | schema.registry.basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | specific.avro.reader = false connect-debezium_1_7f42f918637d | value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,819 INFO || AvroDataConfig values: connect-debezium_1_7f42f918637d | schemas.cache.config = 1000 connect-debezium_1_7f42f918637d | enhanced.avro.schema.support = false connect-debezium_1_7f42f918637d | connect.meta.data = true connect-debezium_1_7f42f918637d | [io.confluent.connect.avro.AvroDataConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,820 INFO || AvroConverterConfig values: connect-debezium_1_7f42f918637d | schema.registry.url = [http://schema-registry:8081] connect-debezium_1_7f42f918637d | basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | auto.register.schemas = true connect-debezium_1_7f42f918637d | max.schemas.per.subject = 1000 connect-debezium_1_7f42f918637d | basic.auth.credentials.source = URL connect-debezium_1_7f42f918637d | schema.registry.basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | [io.confluent.connect.avro.AvroConverterConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,820 INFO || KafkaAvroSerializerConfig values: connect-debezium_1_7f42f918637d | schema.registry.url = [http://schema-registry:8081] connect-debezium_1_7f42f918637d | basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | auto.register.schemas = true connect-debezium_1_7f42f918637d | max.schemas.per.subject = 1000 connect-debezium_1_7f42f918637d | basic.auth.credentials.source = URL connect-debezium_1_7f42f918637d | schema.registry.basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,821 INFO || KafkaAvroDeserializerConfig values: connect-debezium_1_7f42f918637d | schema.registry.url = [http://schema-registry:8081] connect-debezium_1_7f42f918637d | basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | auto.register.schemas = true connect-debezium_1_7f42f918637d | max.schemas.per.subject = 1000 connect-debezium_1_7f42f918637d | basic.auth.credentials.source = URL connect-debezium_1_7f42f918637d | schema.registry.basic.auth.user.info = [hidden] connect-debezium_1_7f42f918637d | specific.avro.reader = false connect-debezium_1_7f42f918637d | value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy connect-debezium_1_7f42f918637d | [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,821 INFO || AvroDataConfig values: connect-debezium_1_7f42f918637d | schemas.cache.config = 1000 connect-debezium_1_7f42f918637d | enhanced.avro.schema.support = false connect-debezium_1_7f42f918637d | connect.meta.data = true connect-debezium_1_7f42f918637d | [io.confluent.connect.avro.AvroDataConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,821 INFO || Set up the key converter class io.confluent.connect.avro.AvroConverter for task ora-source-debezium-xstream-0 using the connector config [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,821 INFO || Set up the value converter class io.confluent.connect.avro.AvroConverter for task ora-source-debezium-xstream-0 using the connector config [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,825 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task ora-source-debezium-xstream-0 using the worker config [org.apache.kafka.connect.runtime.Worker] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,873 INFO || ProducerConfig values: connect-debezium_1_7f42f918637d | acks = all connect-debezium_1_7f42f918637d | batch.size = 16384 connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | buffer.memory = 33554432 connect-debezium_1_7f42f918637d | client.id = connect-debezium_1_7f42f918637d | compression.type = none connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | enable.idempotence = false connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer connect-debezium_1_7f42f918637d | linger.ms = 0 connect-debezium_1_7f42f918637d | max.block.ms = 9223372036854775807 connect-debezium_1_7f42f918637d | max.in.flight.requests.per.connection = 1 connect-debezium_1_7f42f918637d | max.request.size = 1048576 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner connect-debezium_1_7f42f918637d | receive.buffer.bytes = 32768 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 2147483647 connect-debezium_1_7f42f918637d | retries = 2147483647 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | transaction.timeout.ms = 60000 connect-debezium_1_7f42f918637d | transactional.id = null connect-debezium_1_7f42f918637d | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,887 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,887 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,932 INFO || Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,973 INFO || Starting OracleConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,978 INFO || connector.class = io.debezium.connector.oracle.OracleConnector [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,978 INFO || database.user = c##xstrm [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,978 INFO || database.dbname = ORCLCDB [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,978 INFO || transforms.InsertSourceDetails.static.field = messagesource [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,979 INFO || database.pdb.name = ORCLPDB1 [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,979 INFO || database.history.kafka.topic = schema-changes.inventory [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,979 INFO || transforms.InsertTopic.type = org.apache.kafka.connect.transforms.InsertField$Value [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,979 INFO || database.history.kafka.bootstrap.servers = kafka:29092 [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,980 INFO || transforms = InsertTopic,InsertSourceDetails [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,980 INFO || database.server.name = asgard [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,982 INFO || include.schema.changes = true [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,982 INFO || transforms.InsertTopic.topic.field = messagetopic [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,982 INFO || database.port = 1521 [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,983 INFO || value.converter.schema.registry.url = http://schema-registry:8081 [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,983 INFO || transforms.InsertSourceDetails.type = org.apache.kafka.connect.transforms.InsertField$Value [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,983 INFO || task.class = io.debezium.connector.oracle.OracleConnectorTask [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,983 INFO || database.hostname = oracle [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,983 INFO || database.password = ******** [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,984 INFO || name = ora-source-debezium-xstream [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,986 INFO || database.out.server.name = dbzxout_new [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,986 INFO || value.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,987 INFO || transforms.InsertSourceDetails.static.value = Debezium CDC from Oracle on asgard [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,987 INFO || key.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:32,987 INFO || key.converter.schema.registry.url = http://schema-registry:8081 [io.debezium.connector.common.BaseSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,025 INFO || Requested thread factory for connector OracleConnector, id = asgard named = error-handler [io.debezium.util.Threads] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,196 INFO || KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=asgard-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=kafka:29092, client.id=asgard-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1} [io.debezium.relational.history.KafkaDatabaseHistory] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,196 INFO || KafkaDatabaseHistory Producer config: {bootstrap.servers=kafka:29092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=asgard-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1} [io.debezium.relational.history.KafkaDatabaseHistory] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,198 INFO || ProducerConfig values: connect-debezium_1_7f42f918637d | acks = 1 connect-debezium_1_7f42f918637d | batch.size = 32768 connect-debezium_1_7f42f918637d | bootstrap.servers = [kafka:29092] connect-debezium_1_7f42f918637d | buffer.memory = 1048576 connect-debezium_1_7f42f918637d | client.id = asgard-dbhistory connect-debezium_1_7f42f918637d | compression.type = none connect-debezium_1_7f42f918637d | connections.max.idle.ms = 540000 connect-debezium_1_7f42f918637d | enable.idempotence = false connect-debezium_1_7f42f918637d | interceptor.classes = [] connect-debezium_1_7f42f918637d | key.serializer = class org.apache.kafka.common.serialization.StringSerializer connect-debezium_1_7f42f918637d | linger.ms = 0 connect-debezium_1_7f42f918637d | max.block.ms = 10000 connect-debezium_1_7f42f918637d | max.in.flight.requests.per.connection = 5 connect-debezium_1_7f42f918637d | max.request.size = 1048576 connect-debezium_1_7f42f918637d | metadata.max.age.ms = 300000 connect-debezium_1_7f42f918637d | metric.reporters = [] connect-debezium_1_7f42f918637d | metrics.num.samples = 2 connect-debezium_1_7f42f918637d | metrics.recording.level = INFO connect-debezium_1_7f42f918637d | metrics.sample.window.ms = 30000 connect-debezium_1_7f42f918637d | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner connect-debezium_1_7f42f918637d | receive.buffer.bytes = 32768 connect-debezium_1_7f42f918637d | reconnect.backoff.max.ms = 1000 connect-debezium_1_7f42f918637d | reconnect.backoff.ms = 50 connect-debezium_1_7f42f918637d | request.timeout.ms = 30000 connect-debezium_1_7f42f918637d | retries = 1 connect-debezium_1_7f42f918637d | retry.backoff.ms = 100 connect-debezium_1_7f42f918637d | sasl.client.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.jaas.config = null connect-debezium_1_7f42f918637d | sasl.kerberos.kinit.cmd = /usr/bin/kinit connect-debezium_1_7f42f918637d | sasl.kerberos.min.time.before.relogin = 60000 connect-debezium_1_7f42f918637d | sasl.kerberos.service.name = null connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.kerberos.ticket.renew.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.callback.handler.class = null connect-debezium_1_7f42f918637d | sasl.login.class = null connect-debezium_1_7f42f918637d | sasl.login.refresh.buffer.seconds = 300 connect-debezium_1_7f42f918637d | sasl.login.refresh.min.period.seconds = 60 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.factor = 0.8 connect-debezium_1_7f42f918637d | sasl.login.refresh.window.jitter = 0.05 connect-debezium_1_7f42f918637d | sasl.mechanism = GSSAPI connect-debezium_1_7f42f918637d | security.protocol = PLAINTEXT connect-debezium_1_7f42f918637d | send.buffer.bytes = 131072 connect-debezium_1_7f42f918637d | ssl.cipher.suites = null connect-debezium_1_7f42f918637d | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] connect-debezium_1_7f42f918637d | ssl.endpoint.identification.algorithm = https connect-debezium_1_7f42f918637d | ssl.key.password = null connect-debezium_1_7f42f918637d | ssl.keymanager.algorithm = SunX509 connect-debezium_1_7f42f918637d | ssl.keystore.location = null connect-debezium_1_7f42f918637d | ssl.keystore.password = null connect-debezium_1_7f42f918637d | ssl.keystore.type = JKS connect-debezium_1_7f42f918637d | ssl.protocol = TLS connect-debezium_1_7f42f918637d | ssl.provider = null connect-debezium_1_7f42f918637d | ssl.secure.random.implementation = null connect-debezium_1_7f42f918637d | ssl.trustmanager.algorithm = PKIX connect-debezium_1_7f42f918637d | ssl.truststore.location = null connect-debezium_1_7f42f918637d | ssl.truststore.password = null connect-debezium_1_7f42f918637d | ssl.truststore.type = JKS connect-debezium_1_7f42f918637d | transaction.timeout.ms = 60000 connect-debezium_1_7f42f918637d | transactional.id = null connect-debezium_1_7f42f918637d | value.serializer = class org.apache.kafka.common.serialization.StringSerializer connect-debezium_1_7f42f918637d | [org.apache.kafka.clients.producer.ProducerConfig] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,209 INFO || Kafka version : 2.0.0 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,209 INFO || Kafka commitId : 3402a8361b734732 [org.apache.kafka.common.utils.AppInfoParser] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,288 INFO || Requested thread factory for connector OracleConnector, id = asgard named = change-event-source-coordinator [io.debezium.util.Threads] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,290 INFO || Creating thread debezium-oracleconnector-asgard-change-event-source-coordinator [io.debezium.util.Threads] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:33,291 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:34,709 INFO || Snapshot step 1 - Preparing [io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:34,709 INFO || Snapshot step 2 - Determining captured tables [io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:36,809 INFO || Snapshot step 3 - Locking captured tables [io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,003 INFO || Snapshot step 8 - Finalizing [io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,015 ERROR || Producer failure [io.debezium.pipeline.ErrorHandler] connect-debezium_1_7f42f918637d | java.lang.RuntimeException: java.sql.SQLException: ORA-46385: DML and DDL operations are not allowed on table "AUDSYS"."AUD$UNIFIED". connect-debezium_1_7f42f918637d | connect-debezium_1_7f42f918637d | at io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource.execute(HistorizedRelationalSnapshotChangeEventSource.java:145) connect-debezium_1_7f42f918637d | at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:64) connect-debezium_1_7f42f918637d | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) connect-debezium_1_7f42f918637d | at java.util.concurrent.FutureTask.run(FutureTask.java:266) connect-debezium_1_7f42f918637d | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) connect-debezium_1_7f42f918637d | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) connect-debezium_1_7f42f918637d | at java.lang.Thread.run(Thread.java:748) connect-debezium_1_7f42f918637d | Caused by: java.sql.SQLException: ORA-46385: DML and DDL operations are not allowed on table "AUDSYS"."AUD$UNIFIED". connect-debezium_1_7f42f918637d | connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1136) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1039) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CStatement.executeForDescribe(T2CStatement.java:920) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CStatement.executeForRows(T2CStatement.java:1163) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1119) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1737) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1692) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:300) connect-debezium_1_7f42f918637d | at io.debezium.connector.oracle.OracleSnapshotChangeEventSource.lockTablesForSchemaSnapshot(OracleSnapshotChangeEventSource.java:98) connect-debezium_1_7f42f918637d | at io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource.execute(HistorizedRelationalSnapshotChangeEventSource.java:103) connect-debezium_1_7f42f918637d | ... 6 more connect-debezium_1_7f42f918637d | Caused by: Error : 46385, Position : 18, Sql = LOCK TABLE AUDSYS.AUD$UNIFIED IN EXCLUSIVE MODE, OriginalSql = LOCK TABLE AUDSYS.AUD$UNIFIED IN EXCLUSIVE MODE, Error Msg = ORA-46385: DML and DDL operations are not allowed on table "AUDSYS"."AUD$UNIFIED". connect-debezium_1_7f42f918637d | connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1145) connect-debezium_1_7f42f918637d | ... 15 more connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,029 INFO || Creating thread debezium-oracleconnector-asgard-error-handler [io.debezium.util.Threads] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,039 ERROR || Interrupted while stopping [io.debezium.connector.oracle.OracleConnectorTask] connect-debezium_1_7f42f918637d | java.lang.InterruptedException connect-debezium_1_7f42f918637d | at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2067) connect-debezium_1_7f42f918637d | at java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1475) connect-debezium_1_7f42f918637d | at java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:675) connect-debezium_1_7f42f918637d | at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52) connect-debezium_1_7f42f918637d | at io.debezium.connector.oracle.OracleConnectorTask.cleanupResources(OracleConnectorTask.java:153) connect-debezium_1_7f42f918637d | at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42) connect-debezium_1_7f42f918637d | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) connect-debezium_1_7f42f918637d | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) connect-debezium_1_7f42f918637d | at java.lang.Thread.run(Thread.java:748) connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,070 INFO || [Producer clientId=asgard-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. [org.apache.kafka.clients.producer.KafkaProducer] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,520 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,520 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,521 ERROR || WorkerSourceTask{id=ora-source-debezium-xstream-0} Task threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask] connect-debezium_1_7f42f918637d | org.apache.kafka.connect.errors.ConnectException: An exception ocurred in the change event producer. This connector will be stopped. connect-debezium_1_7f42f918637d | at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:168) connect-debezium_1_7f42f918637d | at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:149) connect-debezium_1_7f42f918637d | at io.debezium.connector.oracle.OracleConnectorTask.poll(OracleConnectorTask.java:108) connect-debezium_1_7f42f918637d | at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:244) connect-debezium_1_7f42f918637d | at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:220) connect-debezium_1_7f42f918637d | at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175) connect-debezium_1_7f42f918637d | at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219) connect-debezium_1_7f42f918637d | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) connect-debezium_1_7f42f918637d | at java.util.concurrent.FutureTask.run(FutureTask.java:266) connect-debezium_1_7f42f918637d | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) connect-debezium_1_7f42f918637d | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) connect-debezium_1_7f42f918637d | at java.lang.Thread.run(Thread.java:748) connect-debezium_1_7f42f918637d | Caused by: java.lang.RuntimeException: java.sql.SQLException: ORA-46385: DML and DDL operations are not allowed on table "AUDSYS"."AUD$UNIFIED". connect-debezium_1_7f42f918637d | connect-debezium_1_7f42f918637d | at io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource.execute(HistorizedRelationalSnapshotChangeEventSource.java:145) connect-debezium_1_7f42f918637d | at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:64) connect-debezium_1_7f42f918637d | ... 5 more connect-debezium_1_7f42f918637d | Caused by: java.sql.SQLException: ORA-46385: DML and DDL operations are not allowed on table "AUDSYS"."AUD$UNIFIED". connect-debezium_1_7f42f918637d | connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1136) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1039) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CStatement.executeForDescribe(T2CStatement.java:920) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CStatement.executeForRows(T2CStatement.java:1163) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1119) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1737) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1692) connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:300) connect-debezium_1_7f42f918637d | at io.debezium.connector.oracle.OracleSnapshotChangeEventSource.lockTablesForSchemaSnapshot(OracleSnapshotChangeEventSource.java:98) connect-debezium_1_7f42f918637d | at io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource.execute(HistorizedRelationalSnapshotChangeEventSource.java:103) connect-debezium_1_7f42f918637d | ... 6 more connect-debezium_1_7f42f918637d | Caused by: Error : 46385, Position : 18, Sql = LOCK TABLE AUDSYS.AUD$UNIFIED IN EXCLUSIVE MODE, OriginalSql = LOCK TABLE AUDSYS.AUD$UNIFIED IN EXCLUSIVE MODE, Error Msg = ORA-46385: DML and DDL operations are not allowed on table "AUDSYS"."AUD$UNIFIED". connect-debezium_1_7f42f918637d | connect-debezium_1_7f42f918637d | at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1145) connect-debezium_1_7f42f918637d | ... 15 more connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,522 ERROR || WorkerSourceTask{id=ora-source-debezium-xstream-0} Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,523 INFO || Connector has already been stopped [io.debezium.connector.oracle.OracleConnectorTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:58:37,524 INFO || [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] connect-debezium_1_7f42f918637d | 2018-12-04 10:59:32,863 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 10:59:32,864 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:00:32,797 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:00:32,806 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:00:54,161 INFO || Cluster ID: IgNPWrz2QE2Rq1HwpclDJQ [org.apache.kafka.clients.Metadata] connect-debezium_1_7f42f918637d | 2018-12-04 11:01:32,739 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:01:32,739 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:02:32,673 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:02:32,674 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:03:32,608 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:03:32,608 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:04:32,545 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:04:32,545 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:05:32,479 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:05:32,479 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:06:32,410 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:06:32,411 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:07:32,348 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:07:32,348 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:08:32,283 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:08:32,283 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:09:32,225 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:09:32,225 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:10:32,149 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:10:32,150 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:11:32,093 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:11:32,095 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:12:32,028 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:12:32,029 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:13:31,963 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:13:31,963 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:14:31,897 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:14:31,898 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:15:31,831 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:15:31,832 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:16:31,765 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:16:31,765 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:17:01,751 INFO || 172.23.0.1 - - [04/Dec/2018:11:17:01 +0000] "GET /connectors HTTP/1.1" 200 31 29 [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 11:17:01,818 INFO || 172.23.0.1 - - [04/Dec/2018:11:17:01 +0000] "GET /connectors/ora-source-debezium-xstream/status HTTP/1.1" 200 3119 31 [org.apache.kafka.connect.runtime.rest.RestServer] connect-debezium_1_7f42f918637d | 2018-12-04 11:17:31,699 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:17:31,699 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:18:31,633 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] connect-debezium_1_7f42f918637d | 2018-12-04 11:18:31,633 INFO || WorkerSourceTask{id=ora-source-debezium-xstream-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]