Last login: Fri May 31 22:04:48 on ttys001 Ehsanuls-MBP:~ ekhan$ cd ~/project/ek/kafka-debezium-oracle-prototype/kafka-connect Ehsanuls-MBP:kafka-connect ekhan$ connect-distributed connect-distributed.properties [2019-05-31 22:05:22,706] INFO Kafka Connect distributed worker initializing ... (org.apache.kafka.connect.cli.ConnectDistributed:64) [2019-05-31 22:05:22,719] INFO WorkerInfo values: 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=/usr/local/Cellar/kafka/2.1.0/libexec/bin/../logs, -Dlog4j.configuration=file:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../config/connect-log4j.properties jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 1.8.0_192, 25.192-b12 jvm.classpath = /Users/ekhan/Oracle/instantclient_12_1:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/activation-1.1.1.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/aopalliance-repackaged-2.5.0-b42.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/argparse4j-0.7.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/audience-annotations-0.5.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/commons-lang3-3.5.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/compileScala.mapping:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/compileScala.mapping.asc:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/connect-api-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/connect-basic-auth-extension-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/connect-file-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/connect-json-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/connect-runtime-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/connect-transforms-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/guava-20.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/hk2-api-2.5.0-b42.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/hk2-locator-2.5.0-b42.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/hk2-utils-2.5.0-b42.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jackson-annotations-2.9.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jackson-core-2.9.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jackson-databind-2.9.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jackson-jaxrs-base-2.9.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jackson-jaxrs-json-provider-2.9.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jackson-module-jaxb-annotations-2.9.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/javassist-3.22.0-CR2.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/javax.annotation-api-1.2.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/javax.inject-1.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/javax.inject-2.5.0-b42.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/javax.servlet-api-3.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/javax.ws.rs-api-2.1.1.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/javax.ws.rs-api-2.1.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jaxb-api-2.3.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jersey-client-2.27.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jersey-common-2.27.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jersey-container-servlet-2.27.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jersey-container-servlet-core-2.27.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jersey-hk2-2.27.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jersey-media-jaxb-2.27.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jersey-server-2.27.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-client-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-continuation-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-http-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-io-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-security-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-server-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-servlet-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-servlets-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jetty-util-9.4.12.v20180830.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/jopt-simple-5.0.4.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka-clients-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka-log4j-appender-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka-streams-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka-streams-examples-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka-streams-scala_2.12-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka-streams-test-utils-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka-tools-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka_2.12-2.1.0-sources.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/kafka_2.12-2.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/log4j-1.2.17.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/lz4-java-1.5.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/maven-artifact-3.5.4.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/metrics-core-2.2.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/osgi-resource-locator-1.0.1.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/plexus-utils-3.1.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/reflections-0.9.11.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/rocksdbjni-5.14.2.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/scala-library-2.12.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/scala-logging_2.12-3.9.0.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/scala-reflect-2.12.7.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/slf4j-api-1.7.25.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/slf4j-log4j12-1.7.25.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/snappy-java-1.1.7.2.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/validation-api-1.1.0.Final.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/zkclient-0.10.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/zookeeper-3.4.13.jar:/usr/local/Cellar/kafka/2.1.0/libexec/bin/../libs/zstd-jni-1.3.5-4.jar os.spec = Mac OS X, x86_64, 10.14.4 os.vcpus = 12 (org.apache.kafka.connect.runtime.WorkerInfo:71) [2019-05-31 22:05:22,732] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:73) [2019-05-31 22:05:22,763] INFO Loading plugin from: /Users/ekhan/project/ek/kafka-debezium-oracle-prototype/kafka-connect/connectors/debezium-connector-oracle (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:220) [2019-05-31 22:05:23,328] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/ekhan/project/ek/kafka-debezium-oracle-prototype/kafka-connect/connectors/debezium-connector-oracle/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:243) [2019-05-31 22:05:23,328] INFO Added plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:23,329] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:23,329] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:23,329] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:23,329] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,117] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:243) [2019-05-31 22:05:24,117] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,119] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,119] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,119] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,119] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,120] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,120] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,120] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,120] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,120] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,120] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,120] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,121] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,122] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,123] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,123] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:172) [2019-05-31 22:05:24,123] INFO Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,123] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,124] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,124] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,124] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,124] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,124] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,124] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,124] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,125] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,126] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,127] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:390) [2019-05-31 22:05:24,127] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,127] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,127] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,128] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,128] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,128] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,128] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:387) [2019-05-31 22:05:24,142] INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = bootstrap.servers = [localhost:9092] client.dns.lookup = default client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = connect_configs connections.max.idle.ms = 540000 group.id = 1 header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter heartbeat.interval.ms = 3000 internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class io.confluent.connect.avro.AvroConverter listeners = null metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 10000 offset.flush.timeout.ms = 5000 offset.storage.partitions = 1 offset.storage.replication.factor = 1 offset.storage.topic = connect_offsets plugin.path = [connectors] rebalance.timeout.ms = 60000 receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 40000 rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS status.storage.partitions = 1 status.storage.replication.factor = 1 status.storage.topic = connect_status task.shutdown.graceful.timeout.ms = 5000 value.converter = class io.confluent.connect.avro.AvroConverter worker.sync.timeout.ms = 3000 worker.unsync.backoff.ms = 300000 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:279) [2019-05-31 22:05:24,142] 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:322) [2019-05-31 22:05:24,143] 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:322) [2019-05-31 22:05:24,144] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43) [2019-05-31 22:05:24,146] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:279) [2019-05-31 22:05:24,184] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,184] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,184] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,184] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,185] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,186] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,186] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,316] INFO Kafka cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.connect.util.ConnectUtils:59) [2019-05-31 22:05:24,363] INFO Logging initialized @2009ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193) [2019-05-31 22:05:24,412] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:119) [2019-05-31 22:05:24,432] INFO Advertised URI: http://192.168.1.102:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:267) [2019-05-31 22:05:24,442] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,442] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,551] INFO JsonConverterConfig values: converter.type = key schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:279) [2019-05-31 22:05:24,552] INFO JsonConverterConfig values: converter.type = value schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:279) [2019-05-31 22:05:24,573] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,573] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,575] INFO Kafka Connect distributed worker initialization took 1867ms (org.apache.kafka.connect.cli.ConnectDistributed:104) [2019-05-31 22:05:24,575] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:49) [2019-05-31 22:05:24,575] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:163) [2019-05-31 22:05:24,575] INFO Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:213) [2019-05-31 22:05:24,575] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:172) [2019-05-31 22:05:24,576] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108) [2019-05-31 22:05:24,576] INFO Starting KafkaBasedLog with topic connect_offsets (org.apache.kafka.connect.util.KafkaBasedLog:125) [2019-05-31 22:05:24,576] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:279) [2019-05-31 22:05:24,578] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,579] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,580] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,580] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,580] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,580] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,580] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,580] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,617] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:279) [2019-05-31 22:05:24,636] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,636] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,636] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,637] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,638] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,638] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,638] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,638] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,638] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,644] INFO ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = default client.id = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = 1 heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:279) [2019-05-31 22:05:24,665] INFO jetty-9.4.12.v20180830; built: 2018-08-30T13:59:14.071Z; git: 27208684755d94a92186989f695db2d7b21ebc51; jvm 1.8.0_192-b12 (org.eclipse.jetty.server.Server:371) [2019-05-31 22:05:24,667] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,667] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,667] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,667] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,667] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,668] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,669] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,669] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,669] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,669] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,679] INFO Cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.clients.Metadata:285) [2019-05-31 22:05:24,706] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365) [2019-05-31 22:05:24,706] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370) [2019-05-31 22:05:24,708] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:149) [2019-05-31 22:05:24,752] INFO [Consumer clientId=consumer-1, groupId=1] Discovered group coordinator ehsanuls-mbp.socal.rr.com:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:654) [2019-05-31 22:05:24,767] INFO [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition connect_offsets-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,767] INFO [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition connect_offsets-2 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,767] INFO [Consumer clientId=consumer-1, groupId=1] Resetting offset for partition connect_offsets-1 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,767] INFO Finished reading KafkaBasedLog for topic connect_offsets (org.apache.kafka.connect.util.KafkaBasedLog:154) [2019-05-31 22:05:24,768] INFO Started KafkaBasedLog for topic connect_offsets (org.apache.kafka.connect.util.KafkaBasedLog:156) [2019-05-31 22:05:24,768] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110) [2019-05-31 22:05:24,769] INFO Worker started (org.apache.kafka.connect.runtime.Worker:177) [2019-05-31 22:05:24,769] INFO Starting KafkaBasedLog with topic connect_status (org.apache.kafka.connect.util.KafkaBasedLog:125) [2019-05-31 22:05:24,769] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:279) [2019-05-31 22:05:24,772] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,772] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,772] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,772] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,772] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,772] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,773] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,774] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,774] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,774] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,774] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,787] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:279) [2019-05-31 22:05:24,791] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,792] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,793] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,793] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,795] INFO ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = default client.id = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = 1 heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:279) [2019-05-31 22:05:24,800] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,800] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,800] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,800] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,800] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,800] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,801] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,802] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,802] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,802] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,806] INFO Cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.clients.Metadata:285) [2019-05-31 22:05:24,824] INFO [Consumer clientId=consumer-2, groupId=1] Discovered group coordinator ehsanuls-mbp.socal.rr.com:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:654) [2019-05-31 22:05:24,830] INFO [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect_status-1 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,831] INFO [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect_status-2 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,831] INFO [Consumer clientId=consumer-2, groupId=1] Resetting offset for partition connect_status-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,831] INFO Finished reading KafkaBasedLog for topic connect_status (org.apache.kafka.connect.util.KafkaBasedLog:154) [2019-05-31 22:05:24,831] INFO Started KafkaBasedLog for topic connect_status (org.apache.kafka.connect.util.KafkaBasedLog:156) [2019-05-31 22:05:24,832] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:248) [2019-05-31 22:05:24,832] INFO Starting KafkaBasedLog with topic connect_configs (org.apache.kafka.connect.util.KafkaBasedLog:125) [2019-05-31 22:05:24,833] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:279) [2019-05-31 22:05:24,835] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,835] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,835] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,835] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,836] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,837] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,837] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,837] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,837] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:24,837] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,837] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,850] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:279) [2019-05-31 22:05:24,854] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,854] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,854] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,854] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,854] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,854] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,854] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,854] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2019-05-31 22:05:24,855] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,855] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,856] INFO ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = default client.id = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = 1 heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:279) [2019-05-31 22:05:24,860] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,860] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,860] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,860] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,860] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,860] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2019-05-31 22:05:24,861] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:24,861] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:24,866] INFO Cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.clients.Metadata:285) [2019-05-31 22:05:24,883] INFO [Consumer clientId=consumer-3, groupId=1] Discovered group coordinator ehsanuls-mbp.socal.rr.com:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:654) [2019-05-31 22:05:24,889] INFO [Consumer clientId=consumer-3, groupId=1] Resetting offset for partition connect_configs-2 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,889] INFO [Consumer clientId=consumer-3, groupId=1] Resetting offset for partition connect_configs-1 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,889] INFO [Consumer clientId=consumer-3, groupId=1] Resetting offset for partition connect_configs-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:583) [2019-05-31 22:05:24,890] INFO Finished reading KafkaBasedLog for topic connect_configs (org.apache.kafka.connect.util.KafkaBasedLog:154) [2019-05-31 22:05:24,890] INFO Started KafkaBasedLog for topic connect_configs (org.apache.kafka.connect.util.KafkaBasedLog:156) [2019-05-31 22:05:24,890] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:253) [2019-05-31 22:05:24,890] INFO Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:217) [2019-05-31 22:05:24,897] INFO Cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.clients.Metadata:285) [2019-05-31 22:05:24,898] INFO [Worker clientId=connect-1, groupId=1] Discovered group coordinator ehsanuls-mbp.socal.rr.com:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:654) [2019-05-31 22:05:24,900] INFO [Worker clientId=connect-1, groupId=1] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:486) [2019-05-31 22:05:24,934] INFO [Worker clientId=connect-1, groupId=1] Successfully joined group with generation 100 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:450) [2019-05-31 22:05:24,934] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-cdb830f9-71ae-4f64-a36c-3d38ce7188e1', leaderUrl='http://192.168.1.102:8083/', offset=-1, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1217) [2019-05-31 22:05:24,935] INFO Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:858) [2019-05-31 22:05:24,935] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:868) May 31, 2019 10:05:25 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime 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. May 31, 2019 10:05:25 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime 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. May 31, 2019 10:05:25 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime 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. May 31, 2019 10:05:25 PM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. [2019-05-31 22:05:25,249] INFO Started o.e.j.s.ServletContextHandler@c6e0f32{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:850) [2019-05-31 22:05:25,258] INFO Started http_8083@24e08d59{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:292) [2019-05-31 22:05:25,259] INFO Started @2905ms (org.eclipse.jetty.server.Server:408) [2019-05-31 22:05:25,259] INFO Advertised URI: http://192.168.1.102:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:267) [2019-05-31 22:05:25,259] INFO REST server listening at http://192.168.1.102:8083/, advertising URL http://192.168.1.102:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:217) [2019-05-31 22:05:25,259] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55) [2019-05-31 22:05:37,873] INFO Cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.clients.Metadata:285) [2019-05-31 22:05:37,921] INFO Connector oracle-source-connector config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1098) [2019-05-31 22:05:38,424] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1239) [2019-05-31 22:05:38,424] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1269) [2019-05-31 22:05:38,424] INFO [Worker clientId=connect-1, groupId=1] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:486) [2019-05-31 22:05:38,431] INFO [Worker clientId=connect-1, groupId=1] Successfully joined group with generation 101 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:450) [2019-05-31 22:05:38,431] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-cdb830f9-71ae-4f64-a36c-3d38ce7188e1', leaderUrl='http://192.168.1.102:8083/', offset=1, connectorIds=[oracle-source-connector], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1217) [2019-05-31 22:05:38,431] INFO Starting connectors and tasks using config offset 1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:858) [2019-05-31 22:05:38,432] INFO Starting connector oracle-source-connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:912) [2019-05-31 22:05:38,432] INFO ConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2019-05-31 22:05:38,433] INFO EnrichedConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2019-05-31 22:05:38,433] INFO Creating connector oracle-source-connector of type io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker:235) [2019-05-31 22:05:38,435] INFO Instantiated connector oracle-source-connector with version 0.9.3.Final of type class io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker:238) [2019-05-31 22:05:38,442] INFO Cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.clients.Metadata:285) [2019-05-31 22:05:38,442] INFO Finished creating connector oracle-source-connector (org.apache.kafka.connect.runtime.Worker:257) [2019-05-31 22:05:38,443] INFO SourceConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2019-05-31 22:05:38,444] INFO EnrichedConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2019-05-31 22:05:38,467] INFO 0:0:0:0:0:0:0:1 - - [01/Jun/2019:05:05:37 +0000] "POST /connectors/ HTTP/1.1" 201 544 720 (org.apache.kafka.connect.runtime.rest.RestServer:60) [2019-05-31 22:05:39,438] INFO Tasks [oracle-source-connector-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1113) [2019-05-31 22:05:39,945] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:868) [2019-05-31 22:05:39,945] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1239) [2019-05-31 22:05:39,946] INFO Stopping connector oracle-source-connector (org.apache.kafka.connect.runtime.Worker:338) [2019-05-31 22:05:39,947] INFO Stopped connector oracle-source-connector (org.apache.kafka.connect.runtime.Worker:354) [2019-05-31 22:05:39,949] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1269) [2019-05-31 22:05:39,949] INFO [Worker clientId=connect-1, groupId=1] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:486) [2019-05-31 22:05:39,953] INFO [Worker clientId=connect-1, groupId=1] Successfully joined group with generation 102 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:450) [2019-05-31 22:05:39,953] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-cdb830f9-71ae-4f64-a36c-3d38ce7188e1', leaderUrl='http://192.168.1.102:8083/', offset=1, connectorIds=[oracle-source-connector], taskIds=[oracle-source-connector-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1217) [2019-05-31 22:05:39,953] INFO Starting connectors and tasks using config offset 1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:858) [2019-05-31 22:05:39,954] INFO Starting connector oracle-source-connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:912) [2019-05-31 22:05:39,954] INFO Starting task oracle-source-connector-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:872) [2019-05-31 22:05:39,954] INFO Creating task oracle-source-connector-0 (org.apache.kafka.connect.runtime.Worker:396) [2019-05-31 22:05:39,954] INFO ConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2019-05-31 22:05:39,954] INFO ConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2019-05-31 22:05:39,954] INFO EnrichedConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2019-05-31 22:05:39,955] INFO EnrichedConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2019-05-31 22:05:39,955] INFO Creating connector oracle-source-connector of type io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker:235) [2019-05-31 22:05:39,955] INFO Instantiated connector oracle-source-connector with version 0.9.3.Final of type class io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker:238) [2019-05-31 22:05:39,956] INFO Finished creating connector oracle-source-connector (org.apache.kafka.connect.runtime.Worker:257) [2019-05-31 22:05:39,956] INFO SourceConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2019-05-31 22:05:39,956] INFO EnrichedConnectorConfig values: config.action.reload = RESTART connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oracle-source-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2019-05-31 22:05:39,957] INFO TaskConfig values: task.class = class io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.TaskConfig:279) [2019-05-31 22:05:39,958] INFO Instantiated task oracle-source-connector-0 with version 0.9.3.Final of type io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.Worker:411) [2019-05-31 22:05:39,964] INFO AvroConverterConfig values: schema.registry.url = [http://localhost:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2019-05-31 22:05:40,078] INFO KafkaAvroSerializerConfig values: schema.registry.url = [http://localhost:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2019-05-31 22:05:40,080] INFO KafkaAvroDeserializerConfig values: schema.registry.url = [http://localhost:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2019-05-31 22:05:40,204] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2019-05-31 22:05:40,205] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task oracle-source-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:434) [2019-05-31 22:05:40,205] INFO AvroConverterConfig values: schema.registry.url = [http://localhost:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2019-05-31 22:05:40,205] INFO KafkaAvroSerializerConfig values: schema.registry.url = [http://localhost:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2019-05-31 22:05:40,205] INFO KafkaAvroDeserializerConfig values: schema.registry.url = [http://localhost:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2019-05-31 22:05:40,205] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2019-05-31 22:05:40,205] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task oracle-source-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:440) [2019-05-31 22:05:40,205] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task oracle-source-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:446) [2019-05-31 22:05:40,210] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 2147483647 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:279) [2019-05-31 22:05:40,213] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:40,213] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:40,217] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:868) [2019-05-31 22:05:40,228] INFO Starting OracleConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:42) [2019-05-31 22:05:40,229] INFO connector.class = io.debezium.connector.oracle.OracleConnector (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,229] INFO database.user = system (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,229] INFO database.dbname = E1Local (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO tasks.max = 1 (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO database.history.kafka.bootstrap.servers = localhost:9092 (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO database.history.kafka.topic = schema-changes.customer (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO database.server.name = E1Local (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO database.port = 1521 (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO table.whitelist = XSTRMADMIN.customers (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO task.class = io.debezium.connector.oracle.OracleConnectorTask (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO database.hostname = VAIO (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO name = oracle-source-connector (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,230] INFO database.out.server.name = dbzxout (io.debezium.connector.common.BaseSourceTask:44) [2019-05-31 22:05:40,269] INFO KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=E1Local-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=localhost:9092, client.id=E1Local-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1} (io.debezium.relational.history.KafkaDatabaseHistory:163) [2019-05-31 22:05:40,270] INFO KafkaDatabaseHistory Producer config: {bootstrap.servers=localhost:9092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=E1Local-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1} (io.debezium.relational.history.KafkaDatabaseHistory:164) [2019-05-31 22:05:40,270] INFO ProducerConfig values: acks = 1 batch.size = 32768 bootstrap.servers = [localhost:9092] buffer.memory = 1048576 client.dns.lookup = default client.id = E1Local-dbhistory compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 10000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 1 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.StringSerializer (org.apache.kafka.clients.producer.ProducerConfig:279) [2019-05-31 22:05:40,272] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:40,272] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:40,273] INFO ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = default client.id = E1Local-dbhistory connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = E1Local-dbhistory heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:279) [2019-05-31 22:05:40,275] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:40,275] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:40,278] INFO Cluster ID: v024D1nFSXqi5uNsnHrQbg (org.apache.kafka.clients.Metadata:285) [2019-05-31 22:05:40,286] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = default client.id = E1Local-dbhistory connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 1 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:279) [2019-05-31 22:05:40,287] WARN The configuration 'value.serializer' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:40,288] WARN The configuration 'batch.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:40,288] WARN The configuration 'max.block.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:40,288] WARN The configuration 'acks' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:40,288] WARN The configuration 'buffer.memory' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:40,288] WARN The configuration 'key.serializer' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:40,288] WARN The configuration 'linger.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2019-05-31 22:05:40,288] INFO Kafka version : 2.1.0 (org.apache.kafka.common.utils.AppInfoParser:109) [2019-05-31 22:05:40,288] INFO Kafka commitId : 809be928f1ae004e (org.apache.kafka.common.utils.AppInfoParser:110) [2019-05-31 22:05:40,322] INFO Database history topic '(name=schema-changes.customer, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created (io.debezium.relational.history.KafkaDatabaseHistory:355) [2019-05-31 22:05:40,460] INFO Requested thread factory for connector OracleConnector, id = E1Local named = error-handler (io.debezium.util.Threads:249) [2019-05-31 22:05:40,464] INFO Requested thread factory for connector OracleConnector, id = E1Local named = change-event-source-coordinator (io.debezium.util.Threads:249) [2019-05-31 22:05:40,466] INFO Creating thread debezium-oracleconnector-E1Local-change-event-source-coordinator (io.debezium.util.Threads:265) [2019-05-31 22:05:40,466] INFO WorkerSourceTask{id=oracle-source-connector-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:199) [2019-05-31 22:05:40,471] INFO Snapshot step 1 - Preparing (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:102) [2019-05-31 22:05:41,102] INFO Snapshot step 2 - Determining captured tables (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:113) [2019-05-31 22:05:46,660] INFO Snapshot step 3 - Locking captured tables (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:120) [2019-05-31 22:05:46,665] INFO Snapshot step 4 - Determining snapshot offset (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:126) [2019-05-31 22:05:46,818] INFO Snapshot step 5 - Reading structure of captured tables (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:129) [2019-05-31 22:05:46,818] INFO Snapshot step 6 - Persisting schema history (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:133) [2019-05-31 22:05:46,829] INFO Snapshot step 7 - Snapshotting data (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:145) [2019-05-31 22:05:46,967] INFO Snapshot step 8 - Finalizing (io.debezium.relational.HistorizedRelationalSnapshotChangeEventSource:174) [2019-05-31 22:05:46,977] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:36) java.lang.RuntimeException: java.lang.NoSuchMethodError: oracle.streams.XStreamUtility.convertSCNToPosition(Loracle/sql/NUMBER;I)[B at io.debezium.connector.oracle.OracleStreamingChangeEventSource.execute(OracleStreamingChangeEventSource.java:74) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:86) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.NoSuchMethodError: oracle.streams.XStreamUtility.convertSCNToPosition(Loracle/sql/NUMBER;I)[B at io.debezium.connector.oracle.OracleStreamingChangeEventSource.convertScnToPosition(OracleStreamingChangeEventSource.java:111) at io.debezium.connector.oracle.OracleStreamingChangeEventSource.execute(OracleStreamingChangeEventSource.java:63) ... 6 more [2019-05-31 22:05:46,978] INFO Creating thread debezium-oracleconnector-E1Local-error-handler (io.debezium.util.Threads:265) [2019-05-31 22:05:46,979] ERROR Interrupted while stopping (io.debezium.connector.oracle.OracleConnectorTask:159) java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2067) at java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1475) at java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:675) at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52) at io.debezium.connector.oracle.OracleConnectorTask.cleanupResources(OracleConnectorTask.java:154) at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2019-05-31 22:05:46,991] INFO [Producer clientId=E1Local-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1136) [2019-05-31 22:05:47,460] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:05:47,460] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:05:47,461] ERROR WorkerSourceTask{id=oracle-source-connector-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:177) org.apache.kafka.connect.errors.ConnectException: An exception ocurred in the change event producer. This connector will be stopped. at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:170) at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151) at io.debezium.connector.oracle.OracleConnectorTask.poll(OracleConnectorTask.java:109) at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:244) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:220) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.RuntimeException: java.lang.NoSuchMethodError: oracle.streams.XStreamUtility.convertSCNToPosition(Loracle/sql/NUMBER;I)[B at io.debezium.connector.oracle.OracleStreamingChangeEventSource.execute(OracleStreamingChangeEventSource.java:74) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:86) ... 5 more Caused by: java.lang.NoSuchMethodError: oracle.streams.XStreamUtility.convertSCNToPosition(Loracle/sql/NUMBER;I)[B at io.debezium.connector.oracle.OracleStreamingChangeEventSource.convertScnToPosition(OracleStreamingChangeEventSource.java:111) at io.debezium.connector.oracle.OracleStreamingChangeEventSource.execute(OracleStreamingChangeEventSource.java:63) ... 6 more [2019-05-31 22:05:47,461] ERROR WorkerSourceTask{id=oracle-source-connector-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:178) [2019-05-31 22:05:47,461] INFO Connector has already been stopped (io.debezium.connector.oracle.OracleConnectorTask:136) [2019-05-31 22:05:47,462] INFO [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1136) [2019-05-31 22:05:50,218] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:05:50,219] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:06:00,224] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:06:00,224] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:06:10,225] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:06:10,225] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:06:20,228] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:06:20,228] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:06:30,229] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:06:30,230] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:06:40,235] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:06:40,235] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:06:50,240] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:06:50,240] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:07:00,242] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:07:00,242] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414) [2019-05-31 22:07:10,247] INFO WorkerSourceTask{id=oracle-source-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397) [2019-05-31 22:07:10,247] INFO WorkerSourceTask{id=oracle-source-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)