curl: (7) Failed to connect to localhost port 8081: Connection refused curl: (7) Failed to connect to localhost port 8081: Connection refused curl: (7) Failed to connect to localhost port 8081: Connection refused curl: (7) Failed to connect to localhost port 8081: Connection refused curl: (7) Failed to connect to localhost port 8081: Connection refused curl: (7) Failed to connect to localhost port 8081: Connection refused curl: (7) Failed to connect to localhost port 8081: Connection refused {} [2020-01-28 06:08:29,018] INFO WorkerInfo values: jvm.args = -Xmx640M, -Xms128M, -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, -Dcom.sun.management.jmxremote.local.only=false, -Djava.rmi.server.hostname=localhost, -Dcom.sun.management.jmxremote.rmi.port=9584, -Dcom.sun.management.jmxremote.port=9584, -Dkafka.logs.dir=/opt/landoop/kafka/logs, -Dlog4j.configuration=file:/var/run/connect/connect-log4j.properties jvm.spec = IcedTea, OpenJDK 64-Bit Server VM, 1.8.0_232, 25.232-b09 jvm.classpath = /opt/landoop/kafka/share/java/kafka/activation-1.1.1.jar:/opt/landoop/kafka/share/java/kafka/aopalliance-repackaged-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/argparse4j-0.7.0.jar:/opt/landoop/kafka/share/java/kafka/audience-annotations-0.5.0.jar:/opt/landoop/kafka/share/java/kafka/commons-lang3-3.8.1.jar:/opt/landoop/kafka/share/java/kafka/connect-api-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-basic-auth-extension-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-file-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-json-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-runtime-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-transforms-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/guava-20.0.jar:/opt/landoop/kafka/share/java/kafka/hk2-api-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/hk2-locator-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/hk2-utils-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/jackson-annotations-2.10.0.jar:/opt/landoop/kafka/share/java/kafka/jackson-core-2.10.0.jar:/opt/landoop/kafka/share/java/kafka/jackson-databind-2.10.0.jar:/opt/landoop/kafka/share/java/kafka/jackson-datatype-jdk8-2.10.0.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-base-2.10.0.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-json-provider-2.10.0.jar:/opt/landoop/kafka/share/java/kafka/jackson-module-jaxb-annotations-2.10.0.jar:/opt/landoop/kafka/share/java/kafka/jakarta.activation-api-1.2.1.jar:/opt/landoop/kafka/share/java/kafka/jakarta.xml.bind-api-2.3.2.jar:/opt/landoop/kafka/share/java/kafka/javassist-3.22.0-CR2.jar:/opt/landoop/kafka/share/java/kafka/javax.annotation-api-1.2.jar:/opt/landoop/kafka/share/java/kafka/javax.inject-1.jar:/opt/landoop/kafka/share/java/kafka/javax.inject-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/javax.servlet-api-3.1.0.jar:/opt/landoop/kafka/share/java/kafka/javax.ws.rs-api-2.1.1.jar:/opt/landoop/kafka/share/java/kafka/javax.ws.rs-api-2.1.jar:/opt/landoop/kafka/share/java/kafka/jaxb-api-2.3.0.jar:/opt/landoop/kafka/share/java/kafka/jersey-client-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-common-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-core-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-hk2-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-media-jaxb-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-server-2.27.jar:/opt/landoop/kafka/share/java/kafka/jetty-client-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-continuation-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-http-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-io-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-security-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-server-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlet-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlets-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jetty-util-9.4.14.v20181114.jar:/opt/landoop/kafka/share/java/kafka/jopt-simple-5.0.4.jar:/opt/landoop/kafka/share/java/kafka/kafka-clients-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-custom-principal-builder-1.0-SNAPSHOT.jar:/opt/landoop/kafka/share/java/kafka/kafka-log4j-appender-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-examples-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-scala_2.12-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-test-utils-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-tools-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.12-2.2.2-L0-sources.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.12-2.2.2-L0.jar:/opt/landoop/kafka/share/java/kafka/log4j-1.2.17.jar:/opt/landoop/kafka/share/java/kafka/lz4-java-1.5.0.jar:/opt/landoop/kafka/share/java/kafka/maven-artifact-3.6.0.jar:/opt/landoop/kafka/share/java/kafka/metrics-core-2.2.0.jar:/opt/landoop/kafka/share/java/kafka/osgi-resource-locator-1.0.1.jar:/opt/landoop/kafka/share/java/kafka/plexus-utils-3.1.0.jar:/opt/landoop/kafka/share/java/kafka/reflections-0.9.11.jar:/opt/landoop/kafka/share/java/kafka/rocksdbjni-5.15.10.jar:/opt/landoop/kafka/share/java/kafka/scala-library-2.12.8.jar:/opt/landoop/kafka/share/java/kafka/scala-logging_2.12-3.9.0.jar:/opt/landoop/kafka/share/java/kafka/scala-reflect-2.12.8.jar:/opt/landoop/kafka/share/java/kafka/slf4j-api-1.7.25.jar:/opt/landoop/kafka/share/java/kafka/slf4j-log4j12-1.7.25.jar:/opt/landoop/kafka/share/java/kafka/snappy-java-1.1.7.2.jar:/opt/landoop/kafka/share/java/kafka/validation-api-1.1.0.Final.jar:/opt/landoop/kafka/share/java/kafka/zkclient-0.11.jar:/opt/landoop/kafka/share/java/kafka/zookeeper-3.4.13.jar:/opt/landoop/kafka/share/java/kafka/zstd-jni-1.3.8-1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/avro-1.8.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/commons-compress-1.8.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-annotations-2.9.9.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-core-2.9.9.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-databind-2.9.9.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-avro-serializer-5.2.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.2.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-json-serializer-5.2.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-schema-registry-client-5.2.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.2.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/paranamer-2.7.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/snappy-java-1.1.1.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/xz-1.5.jar:/opt/landoop/kafka/share/java/confluent-common/audience-annotations-0.5.0.jar:/opt/landoop/kafka/share/java/confluent-common/build-tools-5.2.3.jar:/opt/landoop/kafka/share/java/confluent-common/common-config-5.2.3.jar:/opt/landoop/kafka/share/java/confluent-common/common-metrics-5.2.3.jar:/opt/landoop/kafka/share/java/confluent-common/common-utils-5.2.3.jar:/opt/landoop/kafka/share/java/confluent-common/jline-0.9.94.jar:/opt/landoop/kafka/share/java/confluent-common/netty-3.10.6.Final.jar:/opt/landoop/kafka/share/java/confluent-common/slf4j-api-1.7.25.jar:/opt/landoop/kafka/share/java/confluent-common/zkclient-0.10.jar:/opt/landoop/kafka/share/java/confluent-common/zookeeper-3.4.13.jar:/opt/landoop/kafka/share/java/landoop-common/aggdesigner-algorithm-6.0.jar:/opt/landoop/kafka/share/java/landoop-common/antlr4-runtime-4.7.jar:/opt/landoop/kafka/share/java/landoop-common/asm-6.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-analysis-6.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-commons-6.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-tree-6.2.jar:/opt/landoop/kafka/share/java/landoop-common/avatica-core-1.9.0.jar:/opt/landoop/kafka/share/java/landoop-common/avatica-metrics-1.9.0.jar:/opt/landoop/kafka/share/java/landoop-common/avro-1.8.1.jar:/opt/landoop/kafka/share/java/landoop-common/avro4s-core_2.11-1.6.4.jar:/opt/landoop/kafka/share/java/landoop-common/avro4s-macros_2.11-1.6.4.jar:/opt/landoop/kafka/share/java/landoop-common/calcite-core-1.12.0.jar:/opt/landoop/kafka/share/java/landoop-common/calcite-linq4j-1.12.0.jar:/opt/landoop/kafka/share/java/landoop-common/calcite-linq4j-1.8.0.jar:/opt/landoop/kafka/share/java/landoop-common/classmate-1.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-config-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-metrics-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-utils-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/commons-compiler-2.7.6.jar:/opt/landoop/kafka/share/java/landoop-common/commons-compress-1.8.1.jar:/opt/landoop/kafka/share/java/landoop-common/commons-dbcp-1.4.jar:/opt/landoop/kafka/share/java/landoop-common/commons-lang-2.4.jar:/opt/landoop/kafka/share/java/landoop-common/commons-lang3-3.2.jar:/opt/landoop/kafka/share/java/landoop-common/commons-logging-1.1.3.jar:/opt/landoop/kafka/share/java/landoop-common/commons-pool-1.5.4.jar:/opt/landoop/kafka/share/java/landoop-common/connect-api-2.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/connect-json-2.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/guava-19.0.jar:/opt/landoop/kafka/share/java/landoop-common/hibernate-validator-5.1.3.Final.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-annotations-2.9.6.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-core-2.9.7.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-core-asl-1.9.13.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-databind-2.9.7.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-jaxrs-base-2.9.6.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-jaxrs-json-provider-2.9.6.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-mapper-asl-1.9.13.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-module-jaxb-annotations-2.9.6.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-module-paranamer-2.9.1.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-module-scala_2.11-2.9.1.jar:/opt/landoop/kafka/share/java/landoop-common/janino-2.7.6.jar:/opt/landoop/kafka/share/java/landoop-common/javax-websocket-client-impl-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/javax-websocket-server-impl-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/javax.el-2.2.4.jar:/opt/landoop/kafka/share/java/landoop-common/javax.el-api-2.2.4.jar:/opt/landoop/kafka/share/java/landoop-common/javax.websocket-api-1.0.jar:/opt/landoop/kafka/share/java/landoop-common/javax.websocket-client-api-1.0.jar:/opt/landoop/kafka/share/java/landoop-common/jboss-logging-3.1.3.GA.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-bean-validation-2.27.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-annotations-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-client-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-continuation-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-http-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-io-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jaas-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jmx-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jndi-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-plus-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-security-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-server-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-servlet-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-servlets-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-util-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-webapp-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-xml-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jline-0.9.94.jar:/opt/landoop/kafka/share/java/landoop-common/json-sql_2.11-1.0.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-ast_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-core_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-jackson_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-native_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-scalap_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/jsr305-3.0.1.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-avro-serializer-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-clients-2.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-avro-converter-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-smt_2.11-1.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-registry-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-registry-client-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka_2.11-2.0.0-cp1.jar:/opt/landoop/kafka/share/java/landoop-common/kcql-2.8.4.jar:/opt/landoop/kafka/share/java/landoop-common/macro-compat_2.11-1.1.1.jar:/opt/landoop/kafka/share/java/landoop-common/netty-3.10.6.Final.jar:/opt/landoop/kafka/share/java/landoop-common/paranamer-2.8.jar:/opt/landoop/kafka/share/java/landoop-common/rest-utils-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/shapeless_2.11-2.3.2.jar:/opt/landoop/kafka/share/java/landoop-common/sql-core_2.11-1.0.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-api-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-client-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-common-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-server-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-servlet-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/xz-1.5.jar:/opt/landoop/kafka/share/java/landoop-common/zkclient-0.10.jar:/opt/landoop/kafka/share/java/landoop-common/zstd-jni-1.3.5-4.jar os.spec = Linux, amd64, 3.10.0-693.17.1.el7.x86_64 os.vcpus = 32 (org.apache.kafka.connect.runtime.WorkerInfo:71) [2020-01-28 06:08:29,026] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:88) [2020-01-28 06:08:29,051] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-azure-documentdb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:31,827] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-azure-documentdb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:31,828] INFO Added plugin 'com.datamountaineer.streamreactor.connect.azure.documentdb.sink.DocumentDbSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:31,828] INFO Added plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:31,828] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:31,828] INFO Added plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:31,930] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-blockchain (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:34,171] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-blockchain/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:34,171] INFO Added plugin 'com.datamountaineer.streamreactor.connect.blockchain.source.BlockchainSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:34,186] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-bloomberg (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:35,273] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-bloomberg/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:35,273] INFO Added plugin 'com.datamountaineer.streamreactor.connect.bloomberg.BloombergSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:35,287] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-cassandra (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:36,472] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-cassandra/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:36,473] INFO Added plugin 'com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:36,473] INFO Added plugin 'com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:36,488] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-coap (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:37,952] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-coap/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:37,953] INFO Added plugin 'com.datamountaineer.streamreactor.connect.coap.sink.CoapSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:37,953] INFO Added plugin 'com.datamountaineer.streamreactor.connect.coap.source.CoapSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:37,967] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-druid (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:40,333] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-druid/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:40,333] INFO Added plugin 'com.datamountaineer.streamreactor.connect.druid.DruidSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:40,360] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-elastic (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:42,037] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-elastic/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:42,038] INFO Added plugin 'com.datamountaineer.streamreactor.connect.elastic.ElasticSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:42,056] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-elastic5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:44,334] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-elastic5/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:44,334] INFO Added plugin 'com.datamountaineer.streamreactor.connect.elastic5.ElasticSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:44,356] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-elastic6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:46,538] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-elastic6/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:46,539] INFO Added plugin 'com.datamountaineer.streamreactor.connect.elastic6.ElasticSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:46,580] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-ftp (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:47,727] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-ftp/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:47,727] INFO Added plugin 'com.datamountaineer.streamreactor.connect.ftp.source.FtpSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:47,750] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-hazelcast (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:49,120] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-hazelcast/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:49,120] INFO Added plugin 'com.datamountaineer.streamreactor.connect.hazelcast.sink.HazelCastSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:49,135] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-hbase (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:51,271] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-hbase/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:51,272] INFO Added plugin 'com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:51,291] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-hive (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:55,297] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-hive/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:55,297] INFO Added plugin 'com.landoop.streamreactor.connect.hive.sink.HiveSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:55,298] INFO Added plugin 'com.landoop.streamreactor.connect.hive.source.HiveSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:55,332] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-hive-1.1 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:57,672] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-hive-1.1/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:57,688] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-influxdb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:08:58,921] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-influxdb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:08:58,922] INFO Added plugin 'com.datamountaineer.streamreactor.connect.influx.InfluxSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:08:58,936] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-jms (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:00,235] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-jms/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:00,235] INFO Added plugin 'com.datamountaineer.streamreactor.connect.jms.sink.JMSSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:00,235] INFO Added plugin 'com.datamountaineer.streamreactor.connect.jms.source.JMSSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:00,235] INFO Added plugin 'com.datamountaineer.streamreactor.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:00,248] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-kudu (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:01,427] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-kudu/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:01,427] INFO Added plugin 'com.datamountaineer.streamreactor.connect.kudu.sink.KuduSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:01,441] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:02,807] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:02,807] INFO Added plugin 'com.datamountaineer.streamreactor.connect.mongodb.sink.MongoSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:02,826] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-mqtt (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:03,968] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-mqtt/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:03,968] INFO Added plugin 'com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:03,968] INFO Added plugin 'com.datamountaineer.streamreactor.connect.mqtt.sink.MqttSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:03,982] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-pulsar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:05,520] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-pulsar/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:05,520] INFO Added plugin 'com.datamountaineer.streamreactor.connect.pulsar.source.PulsarSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:05,520] INFO Added plugin 'com.datamountaineer.streamreactor.connect.pulsar.sink.PulsarSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:05,548] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-rabbitmq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:06,891] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-rabbitmq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:06,891] INFO Added plugin 'com.datamountaineer.streamreactor.connect.rabbitmq.sink.RabbitMQSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:06,891] INFO Added plugin 'com.datamountaineer.streamreactor.connect.rabbitmq.source.RabbitMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:06,907] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-redis (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:08,203] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-redis/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:08,203] INFO Added plugin 'com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:08,218] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-rethink (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:09,501] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-rethink/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:09,501] INFO Added plugin 'com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:09,501] INFO Added plugin 'com.datamountaineer.streamreactor.connect.rethink.source.ReThinkSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:09,515] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-voltdb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:10,866] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-voltdb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:10,866] INFO Added plugin 'com.datamountaineer.streamreactor.connect.voltdb.VoltSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:10,882] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-couchbase (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:11,681] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-couchbase/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:11,681] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,681] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,682] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:11,847] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:11,847] INFO Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,847] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,847] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,848] INFO Added plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,848] INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,848] INFO Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,848] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:11,849] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-mysql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:12,018] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-mysql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:12,018] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:12,024] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-postgres (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:12,215] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-postgres/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:12,215] INFO Added plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:12,220] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-sqlserver (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:12,324] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-sqlserver/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:12,324] INFO Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:12,344] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:12,494] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:12,494] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:12,495] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-hdfs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:14,825] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-hdfs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:14,825] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:14,825] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:14,825] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:14,825] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:14,825] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:14,853] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:14,950] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:14,951] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:14,951] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:14,960] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:17,156] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:17,157] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:17,192] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-splunk (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:17,410] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-splunk/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:17,411] INFO Added plugin 'com.splunk.kafka.connect.SplunkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:17,411] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:17,411] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:17,412] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-twitter (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:234) [2020-01-28 06:09:18,361] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-twitter/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:18,361] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:18,361] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,523] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:257) [2020-01-28 06:09:19,523] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,524] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,525] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,526] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:186) [2020-01-28 06:09:19,528] INFO Added aliases 'CouchbaseSinkConnector' and 'CouchbaseSink' to plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,529] INFO Added aliases 'CouchbaseSourceConnector' and 'CouchbaseSource' to plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,529] INFO Added aliases 'DocumentDbSinkConnector' and 'DocumentDbSink' to plugin 'com.datamountaineer.streamreactor.connect.azure.documentdb.sink.DocumentDbSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,529] INFO Added aliases 'BlockchainSourceConnector' and 'BlockchainSource' to plugin 'com.datamountaineer.streamreactor.connect.blockchain.source.BlockchainSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,530] INFO Added aliases 'BloombergSourceConnector' and 'BloombergSource' to plugin 'com.datamountaineer.streamreactor.connect.bloomberg.BloombergSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,530] INFO Added aliases 'CassandraSinkConnector' and 'CassandraSink' to plugin 'com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,530] INFO Added aliases 'CassandraSourceConnector' and 'CassandraSource' to plugin 'com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,530] INFO Added aliases 'CoapSinkConnector' and 'CoapSink' to plugin 'com.datamountaineer.streamreactor.connect.coap.sink.CoapSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,531] INFO Added aliases 'CoapSourceConnector' and 'CoapSource' to plugin 'com.datamountaineer.streamreactor.connect.coap.source.CoapSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,531] INFO Added aliases 'DruidSinkConnector' and 'DruidSink' to plugin 'com.datamountaineer.streamreactor.connect.druid.DruidSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,531] INFO Added aliases 'FtpSourceConnector' and 'FtpSource' to plugin 'com.datamountaineer.streamreactor.connect.ftp.source.FtpSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,531] INFO Added aliases 'HazelCastSinkConnector' and 'HazelCastSink' to plugin 'com.datamountaineer.streamreactor.connect.hazelcast.sink.HazelCastSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,531] INFO Added aliases 'HbaseSinkConnector' and 'HbaseSink' to plugin 'com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,532] INFO Added aliases 'InfluxSinkConnector' and 'InfluxSink' to plugin 'com.datamountaineer.streamreactor.connect.influx.InfluxSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,532] INFO Added aliases 'JMSSinkConnector' and 'JMSSink' to plugin 'com.datamountaineer.streamreactor.connect.jms.sink.JMSSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,532] INFO Added aliases 'JMSSourceConnector' and 'JMSSource' to plugin 'com.datamountaineer.streamreactor.connect.jms.source.JMSSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,532] INFO Added aliases 'KuduSinkConnector' and 'KuduSink' to plugin 'com.datamountaineer.streamreactor.connect.kudu.sink.KuduSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,533] INFO Added aliases 'MongoSinkConnector' and 'MongoSink' to plugin 'com.datamountaineer.streamreactor.connect.mongodb.sink.MongoSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,533] INFO Added aliases 'MqttSinkConnector' and 'MqttSink' to plugin 'com.datamountaineer.streamreactor.connect.mqtt.sink.MqttSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,533] INFO Added aliases 'MqttSourceConnector' and 'MqttSource' to plugin 'com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,533] INFO Added aliases 'PulsarSinkConnector' and 'PulsarSink' to plugin 'com.datamountaineer.streamreactor.connect.pulsar.sink.PulsarSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,533] INFO Added aliases 'PulsarSourceConnector' and 'PulsarSource' to plugin 'com.datamountaineer.streamreactor.connect.pulsar.source.PulsarSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,534] INFO Added aliases 'RabbitMQSinkConnector' and 'RabbitMQSink' to plugin 'com.datamountaineer.streamreactor.connect.rabbitmq.sink.RabbitMQSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,534] INFO Added aliases 'RabbitMQSourceConnector' and 'RabbitMQSource' to plugin 'com.datamountaineer.streamreactor.connect.rabbitmq.source.RabbitMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,534] INFO Added aliases 'RedisSinkConnector' and 'RedisSink' to plugin 'com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,535] INFO Added aliases 'ReThinkSinkConnector' and 'ReThinkSink' to plugin 'com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,535] INFO Added aliases 'ReThinkSourceConnector' and 'ReThinkSource' to plugin 'com.datamountaineer.streamreactor.connect.rethink.source.ReThinkSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,535] INFO Added aliases 'VoltSinkConnector' and 'VoltSink' to plugin 'com.datamountaineer.streamreactor.connect.voltdb.VoltSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,536] INFO Added aliases 'TwitterSinkConnector' and 'TwitterSink' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,537] INFO Added aliases 'TwitterSourceConnector' and 'TwitterSource' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,537] INFO Added aliases 'HiveSinkConnector' and 'HiveSink' to plugin 'com.landoop.streamreactor.connect.hive.sink.HiveSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,538] INFO Added aliases 'HiveSourceConnector' and 'HiveSource' to plugin 'com.landoop.streamreactor.connect.hive.source.HiveSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,538] INFO Added aliases 'SplunkSinkConnector' and 'SplunkSink' to plugin 'com.splunk.kafka.connect.SplunkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,538] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,539] INFO Added aliases 'HdfsSinkConnector' and 'HdfsSink' to plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,539] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,539] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,540] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,540] INFO Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,540] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,541] INFO Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,541] INFO Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,541] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,542] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,542] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,542] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,543] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,543] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,543] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,544] INFO Added aliases 'JsonResilientConverter' and 'JsonResilient' to plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,544] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,544] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,544] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,544] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,545] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,545] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,545] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,545] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,545] INFO Added aliases 'JsonResilientConverter' and 'JsonResilient' to plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,546] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,546] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,546] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,546] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,547] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,547] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,547] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,547] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,547] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:403) [2020-01-28 06:09:19,548] INFO Added alias 'Transformation' to plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,548] INFO Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,549] INFO Added alias 'UnwrapFromMongoDbEnvelope' to plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,549] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,549] INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,549] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,550] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,550] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,551] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,551] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,551] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:400) [2020-01-28 06:09:19,563] INFO DistributedConfig values: access.control.allow.methods = GET,POST,PUT,DELETE,OPTIONS access.control.allow.origin = * bootstrap.servers = [PLAINTEXT://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 = connect-fast-data 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 = 60000 offset.flush.timeout.ms = 5000 offset.storage.partitions = 25 offset.storage.replication.factor = 1 offset.storage.topic = connect-offsets plugin.path = [/var/run/connect/connectors/stream-reactor, /var/run/connect/connectors/third-party, /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 = 5 status.storage.replication.factor = 1 status.storage.topic = connect-statuses 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) [2020-01-28 06:09:19,564] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43) [2020-01-28 06:09:19,569] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:19,618] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,618] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,618] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,618] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,618] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,619] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,619] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,619] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,619] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,619] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,619] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,619] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,620] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,620] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,620] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,620] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,620] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:19,621] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:19,621] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:19,772] INFO Kafka cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.connect.util.ConnectUtils:59) [2020-01-28 06:09:19,792] INFO Logging initialized @51696ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193) [2020-01-28 06:09:19,850] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:121) [2020-01-28 06:09:19,850] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:165) [2020-01-28 06:09:19,857] INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git: c4550056e785fb5665914545889f21dc136ad9e6; jvm 1.8.0_232-b09 (org.eclipse.jetty.server.Server:370) [2020-01-28 06:09:19,893] INFO Started http_8083@4c5d1649{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:292) [2020-01-28 06:09:19,894] INFO Started @51798ms (org.eclipse.jetty.server.Server:407) [2020-01-28 06:09:19,918] INFO Advertised URI: http://172.17.0.4:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:283) [2020-01-28 06:09:19,918] INFO REST server listening at http://172.17.0.4:8083/, advertising URL http://172.17.0.4:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:180) [2020-01-28 06:09:19,918] INFO Advertised URI: http://172.17.0.4:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:283) [2020-01-28 06:09:19,931] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:19,932] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,058] INFO JsonConverterConfig values: converter.type = key schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:279) [2020-01-28 06:09:20,059] INFO JsonConverterConfig values: converter.type = value schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:279) [2020-01-28 06:09:20,096] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,096] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,098] INFO Kafka Connect distributed worker initialization took 51072ms (org.apache.kafka.connect.cli.ConnectDistributed:122) [2020-01-28 06:09:20,098] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50) [2020-01-28 06:09:20,100] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:185) [2020-01-28 06:09:20,101] INFO Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:212) [2020-01-28 06:09:20,102] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:173) [2020-01-28 06:09:20,102] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108) [2020-01-28 06:09:20,102] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-01-28 06:09:20,103] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:20,109] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,109] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,110] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,110] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,110] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,110] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,110] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,110] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,111] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,111] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,111] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,111] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,111] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,111] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,111] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,112] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,112] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,112] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,113] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,211] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365) [2020-01-28 06:09:20,212] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370) [2020-01-28 06:09:20,213] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session:149) [2020-01-28 06:09:20,330] INFO Created topic (name=connect-offsets, numPartitions=25, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at PLAINTEXT://localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:230) [2020-01-28 06:09:20,341] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:20,362] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,362] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,362] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,362] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,362] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,363] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,364] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,371] INFO ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [PLAINTEXT://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 = connect-fast-data 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) [2020-01-28 06:09:20,393] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,393] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,393] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,393] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,393] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,393] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,393] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,394] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,394] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,422] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Subscribed to partition(s): connect-offsets-0, connect-offsets-5, connect-offsets-10, connect-offsets-20, connect-offsets-15, connect-offsets-9, connect-offsets-11, connect-offsets-4, connect-offsets-16, connect-offsets-17, connect-offsets-3, connect-offsets-24, connect-offsets-23, connect-offsets-13, connect-offsets-18, connect-offsets-22, connect-offsets-8, connect-offsets-2, connect-offsets-12, connect-offsets-19, connect-offsets-14, connect-offsets-1, connect-offsets-6, connect-offsets-7, connect-offsets-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1090) [2020-01-28 06:09:20,433] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:20,451] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-10 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,453] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-8 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,453] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-14 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,453] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-12 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,453] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-2 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,453] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,453] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-6 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,454] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-4 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,454] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-24 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,454] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-18 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,454] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-16 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,454] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-22 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,454] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-20 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,455] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-9 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,455] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-7 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,455] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:20,455] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-13 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,456] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-11 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,456] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-1 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,456] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-5 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,457] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-3 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,457] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-23 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,457] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-17 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,457] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-15 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,457] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-21 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,458] INFO [Consumer clientId=consumer-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-19 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,459] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-01-28 06:09:20,459] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-01-28 06:09:20,459] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110) [2020-01-28 06:09:20,460] INFO Worker started (org.apache.kafka.connect.runtime.Worker:178) [2020-01-28 06:09:20,461] INFO Starting KafkaBasedLog with topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-01-28 06:09:20,461] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:20,463] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,463] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,463] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,464] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,464] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,464] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,464] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,464] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,464] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,464] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,465] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,465] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,517] INFO Created topic (name=connect-statuses, numPartitions=5, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at PLAINTEXT://localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:230) [2020-01-28 06:09:20,519] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:20,523] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,523] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,524] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,524] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,524] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,524] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,524] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,524] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,524] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,524] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,525] INFO ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [PLAINTEXT://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 = connect-fast-data 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) [2020-01-28 06:09:20,527] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,527] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,527] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,527] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,528] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,528] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,535] INFO [Consumer clientId=consumer-2, groupId=connect-fast-data] Subscribed to partition(s): connect-statuses-0, connect-statuses-4, connect-statuses-1, connect-statuses-2, connect-statuses-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1090) [2020-01-28 06:09:20,536] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:20,541] INFO [Consumer clientId=consumer-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,541] INFO [Consumer clientId=consumer-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-3 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,542] INFO [Consumer clientId=consumer-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-4 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,542] INFO [Consumer clientId=consumer-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-1 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,542] INFO [Consumer clientId=consumer-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-2 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,542] INFO Finished reading KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-01-28 06:09:20,543] INFO Started KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-01-28 06:09:20,544] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:248) [2020-01-28 06:09:20,544] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-01-28 06:09:20,545] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:20,547] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,547] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,548] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,549] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287) [2020-01-28 06:09:20,549] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,549] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,575] INFO Created topic (name=connect-configs, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at PLAINTEXT://localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:230) [2020-01-28 06:09:20,578] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:20,581] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,581] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,582] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287) [2020-01-28 06:09:20,583] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,583] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,583] INFO ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [PLAINTEXT://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 = connect-fast-data 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) [2020-01-28 06:09:20,587] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,587] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,587] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,587] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,587] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287) [2020-01-28 06:09:20,588] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:20,588] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:20,594] INFO [Consumer clientId=consumer-3, groupId=connect-fast-data] Subscribed to partition(s): connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1090) [2020-01-28 06:09:20,596] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:20,599] INFO [Consumer clientId=consumer-3, groupId=connect-fast-data] Resetting offset for partition connect-configs-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584) [2020-01-28 06:09:20,599] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-01-28 06:09:20,599] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-01-28 06:09:20,599] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:253) [2020-01-28 06:09:20,600] INFO Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:216) [2020-01-28 06:09:20,604] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:20,605] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Discovered group coordinator 5eccfbd2898f:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:675) [2020-01-28 06:09:20,607] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) Jan 28, 2020 6:09:20 AM 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. Jan 28, 2020 6:09:20 AM 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. Jan 28, 2020 6:09:20 AM 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. [2020-01-28 06:09:20,614] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) [2020-01-28 06:09:20,624] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:20,683] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:20,775] INFO HV000001: Hibernate Validator 5.1.3.Final (org.hibernate.validator.internal.util.Version:27) Jan 28, 2020 6:09:20 AM 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. [2020-01-28 06:09:20,899] INFO Started o.e.j.s.ServletContextHandler@7469c73d{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:855) [2020-01-28 06:09:20,899] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:231) [2020-01-28 06:09:20,899] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56) [2020-01-28 06:09:21,625] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455) [2020-01-28 06:09:21,626] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-9cdee0c3-56e5-4ef5-8089-e6f701dcfc21', leaderUrl='http://172.17.0.4:8083/', offset=-1, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216) [2020-01-28 06:09:21,628] INFO Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850) [2020-01-28 06:09:21,628] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860) [2020-01-28 06:09:26,588] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:26,647] INFO Connector logs-broker config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1097) [2020-01-28 06:09:27,145] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238) [2020-01-28 06:09:27,146] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268) [2020-01-28 06:09:27,146] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) [2020-01-28 06:09:27,159] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455) [2020-01-28 06:09:27,159] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-9cdee0c3-56e5-4ef5-8089-e6f701dcfc21', leaderUrl='http://172.17.0.4:8083/', offset=1, connectorIds=[logs-broker], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216) [2020-01-28 06:09:27,159] INFO Starting connectors and tasks using config offset 1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850) [2020-01-28 06:09:27,161] INFO Starting connector logs-broker (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904) [2020-01-28 06:09:27,162] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:09:27,163] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:09:27,164] INFO Creating connector logs-broker of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:236) [2020-01-28 06:09:27,169] INFO Instantiated connector logs-broker with version 2.2.2-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:239) [2020-01-28 06:09:27,170] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:27,171] INFO AbstractConfig values: batch.size = 2000 file = /var/log/broker.log topic = [logs_broker] (org.apache.kafka.common.config.AbstractConfig:279) [2020-01-28 06:09:27,182] INFO Finished creating connector logs-broker (org.apache.kafka.connect.runtime.Worker:258) [2020-01-28 06:09:27,184] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:27,185] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2020-01-28 06:09:27,185] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:09:27,185] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:28,162] INFO Tasks [logs-broker-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1112) [2020-01-28 06:09:28,664] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860) [2020-01-28 06:09:28,664] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238) [2020-01-28 06:09:28,666] INFO Stopping connector logs-broker (org.apache.kafka.connect.runtime.Worker:339) [2020-01-28 06:09:28,666] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:28,668] INFO Stopped connector logs-broker (org.apache.kafka.connect.runtime.Worker:355) [2020-01-28 06:09:28,670] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268) [2020-01-28 06:09:28,671] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) [2020-01-28 06:09:28,675] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 3 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455) [2020-01-28 06:09:28,675] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-9cdee0c3-56e5-4ef5-8089-e6f701dcfc21', leaderUrl='http://172.17.0.4:8083/', offset=3, connectorIds=[logs-broker], taskIds=[logs-broker-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216) [2020-01-28 06:09:28,675] INFO Starting connectors and tasks using config offset 3 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850) [2020-01-28 06:09:28,676] INFO Starting connector logs-broker (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904) [2020-01-28 06:09:28,676] INFO Starting task logs-broker-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:864) [2020-01-28 06:09:28,677] INFO Creating task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:397) [2020-01-28 06:09:28,677] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:09:28,677] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:28,678] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:09:28,678] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:09:28,678] INFO Creating connector logs-broker of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:236) [2020-01-28 06:09:28,679] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:09:28,680] INFO Instantiated connector logs-broker with version 2.2.2-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:239) [2020-01-28 06:09:28,680] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:28,680] INFO AbstractConfig values: batch.size = 2000 file = /var/log/broker.log topic = [logs_broker] (org.apache.kafka.common.config.AbstractConfig:279) [2020-01-28 06:09:28,681] INFO Finished creating connector logs-broker (org.apache.kafka.connect.runtime.Worker:258) [2020-01-28 06:09:28,681] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:279) [2020-01-28 06:09:28,682] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:28,682] INFO Instantiated task logs-broker-0 with version 2.2.2-L0 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:412) [2020-01-28 06:09:28,683] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2020-01-28 06:09:28,683] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:09:28,684] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:09:28,698] 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) [2020-01-28 06:09:28,718] 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) [2020-01-28 06:09:28,723] 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) [2020-01-28 06:09:28,914] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:09:28,915] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:435) [2020-01-28 06:09:28,915] 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) [2020-01-28 06:09:28,915] 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) [2020-01-28 06:09:28,916] 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) [2020-01-28 06:09:28,916] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:09:28,916] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:441) [2020-01-28 06:09:28,916] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447) [2020-01-28 06:09:28,923] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:497) [2020-01-28 06:09:28,926] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:09:28,930] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:09:28,930] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:09:28,938] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860) [2020-01-28 06:09:28,940] INFO WorkerSourceTask{id=logs-broker-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:203) [2020-01-28 06:09:29,032] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:09:29,199] WARN [Producer clientId=producer-4] Error while fetching metadata with correlation id 3 : {logs_broker=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:1031) [2020-01-28 06:10:25,911] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,920] INFO Connector coyote_test_console_source-1580191825893 config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1097) [2020-01-28 06:10:25,920] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238) [2020-01-28 06:10:25,923] INFO Stopping connector logs-broker (org.apache.kafka.connect.runtime.Worker:339) [2020-01-28 06:10:25,923] INFO Stopping task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:599) [2020-01-28 06:10:25,923] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,924] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:10:25,925] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:10:25,926] INFO Stopped connector logs-broker (org.apache.kafka.connect.runtime.Worker:355) [2020-01-28 06:10:25,941] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 17 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:10:25,941] INFO [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1145) [2020-01-28 06:10:25,947] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268) [2020-01-28 06:10:25,947] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) [2020-01-28 06:10:25,952] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 4 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455) [2020-01-28 06:10:25,952] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-9cdee0c3-56e5-4ef5-8089-e6f701dcfc21', leaderUrl='http://172.17.0.4:8083/', offset=4, connectorIds=[logs-broker, coyote_test_console_source-1580191825893], taskIds=[logs-broker-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216) [2020-01-28 06:10:25,953] INFO Starting connectors and tasks using config offset 4 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850) [2020-01-28 06:10:25,953] INFO Starting connector logs-broker (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904) [2020-01-28 06:10:25,953] INFO Starting task logs-broker-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:864) [2020-01-28 06:10:25,953] INFO Starting connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904) [2020-01-28 06:10:25,954] INFO Creating task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:397) [2020-01-28 06:10:25,954] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:25,954] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:25,954] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,954] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:25,954] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:25,955] INFO Creating connector coyote_test_console_source-1580191825893 of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:236) [2020-01-28 06:10:25,955] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:25,955] INFO Creating connector logs-broker of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:236) [2020-01-28 06:10:25,956] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:25,956] INFO Instantiated connector coyote_test_console_source-1580191825893 with version 2.2.2-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:239) [2020-01-28 06:10:25,956] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:279) [2020-01-28 06:10:25,957] INFO Instantiated connector logs-broker with version 2.2.2-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:239) [2020-01-28 06:10:25,957] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,957] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,957] INFO Instantiated task logs-broker-0 with version 2.2.2-L0 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:412) [2020-01-28 06:10:25,957] INFO AbstractConfig values: batch.size = 2000 file = /var/log/broker.log topic = [logs_broker] (org.apache.kafka.common.config.AbstractConfig:279) [2020-01-28 06:10:25,957] INFO AbstractConfig values: batch.size = 2000 file = /etc/fstab topic = [coyote_cd-1580191825893] (org.apache.kafka.common.config.AbstractConfig:279) [2020-01-28 06:10:25,958] 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) [2020-01-28 06:10:25,958] INFO Finished creating connector logs-broker (org.apache.kafka.connect.runtime.Worker:258) [2020-01-28 06:10:25,959] INFO Finished creating connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.Worker:258) [2020-01-28 06:10:25,959] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,959] 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) [2020-01-28 06:10:25,959] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2020-01-28 06:10:25,959] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,961] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:25,960] 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) [2020-01-28 06:10:25,961] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,961] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2020-01-28 06:10:25,961] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:25,962] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:25,963] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:435) [2020-01-28 06:10:25,963] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:25,963] 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) [2020-01-28 06:10:25,964] 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) [2020-01-28 06:10:25,964] 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) [2020-01-28 06:10:25,965] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:25,965] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:441) [2020-01-28 06:10:25,965] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447) [2020-01-28 06:10:25,966] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:497) [2020-01-28 06:10:25,967] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:10:25,970] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:10:25,970] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:10:25,972] INFO WorkerSourceTask{id=logs-broker-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:203) [2020-01-28 06:10:26,072] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:10:26,930] INFO Tasks [logs-broker-0, coyote_test_console_source-1580191825893-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1112) [2020-01-28 06:10:27,431] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860) [2020-01-28 06:10:27,432] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238) [2020-01-28 06:10:27,432] INFO Stopping connector logs-broker (org.apache.kafka.connect.runtime.Worker:339) [2020-01-28 06:10:27,432] INFO Stopping connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.Worker:339) [2020-01-28 06:10:27,433] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,432] INFO Stopping task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:599) [2020-01-28 06:10:27,433] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,434] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:10:27,434] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:10:27,435] INFO Stopped connector logs-broker (org.apache.kafka.connect.runtime.Worker:355) [2020-01-28 06:10:27,435] INFO Stopped connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.Worker:355) [2020-01-28 06:10:27,438] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 4 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:10:27,439] INFO [Producer clientId=producer-5] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1145) [2020-01-28 06:10:27,445] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268) [2020-01-28 06:10:27,446] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) [2020-01-28 06:10:27,451] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 5 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455) [2020-01-28 06:10:27,451] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-9cdee0c3-56e5-4ef5-8089-e6f701dcfc21', leaderUrl='http://172.17.0.4:8083/', offset=6, connectorIds=[logs-broker, coyote_test_console_source-1580191825893], taskIds=[logs-broker-0, coyote_test_console_source-1580191825893-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216) [2020-01-28 06:10:27,452] INFO Starting connectors and tasks using config offset 6 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850) [2020-01-28 06:10:27,452] INFO Starting connector logs-broker (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904) [2020-01-28 06:10:27,452] INFO Starting task coyote_test_console_source-1580191825893-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:864) [2020-01-28 06:10:27,452] INFO Starting task logs-broker-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:864) [2020-01-28 06:10:27,452] INFO Starting connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904) [2020-01-28 06:10:27,453] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:27,453] INFO Creating task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:397) [2020-01-28 06:10:27,452] INFO Creating task coyote_test_console_source-1580191825893-0 (org.apache.kafka.connect.runtime.Worker:397) [2020-01-28 06:10:27,453] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,453] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:27,453] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:27,454] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:27,454] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:27,454] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,458] INFO Creating connector coyote_test_console_source-1580191825893 of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:236) [2020-01-28 06:10:27,454] INFO Creating connector logs-broker of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:236) [2020-01-28 06:10:27,460] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:27,460] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:27,461] INFO Instantiated connector coyote_test_console_source-1580191825893 with version 2.2.2-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:239) [2020-01-28 06:10:27,461] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:27,462] INFO Instantiated connector logs-broker with version 2.2.2-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:239) [2020-01-28 06:10:27,461] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,461] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:279) [2020-01-28 06:10:27,463] INFO AbstractConfig values: batch.size = 2000 file = /etc/fstab topic = [coyote_cd-1580191825893] (org.apache.kafka.common.config.AbstractConfig:279) [2020-01-28 06:10:27,462] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,462] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:279) [2020-01-28 06:10:27,464] INFO Finished creating connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.Worker:258) [2020-01-28 06:10:27,464] INFO AbstractConfig values: batch.size = 2000 file = /var/log/broker.log topic = [logs_broker] (org.apache.kafka.common.config.AbstractConfig:279) [2020-01-28 06:10:27,463] INFO Instantiated task logs-broker-0 with version 2.2.2-L0 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:412) [2020-01-28 06:10:27,464] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,464] INFO Instantiated task coyote_test_console_source-1580191825893-0 with version 2.2.2-L0 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:412) [2020-01-28 06:10:27,465] INFO Finished creating connector logs-broker (org.apache.kafka.connect.runtime.Worker:258) [2020-01-28 06:10:27,465] 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) [2020-01-28 06:10:27,465] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2020-01-28 06:10:27,465] 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) [2020-01-28 06:10:27,465] 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) [2020-01-28 06:10:27,467] 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) [2020-01-28 06:10:27,466] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = coyote_test_console_source-1580191825893 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:27,465] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,469] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,470] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2020-01-28 06:10:27,468] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:27,468] 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) [2020-01-28 06:10:27,471] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task coyote_test_console_source-1580191825893-0 using the worker config (org.apache.kafka.connect.runtime.Worker:435) [2020-01-28 06:10:27,471] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:27,471] 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) [2020-01-28 06:10:27,472] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:27,472] 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) [2020-01-28 06:10:27,473] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:27,474] 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) [2020-01-28 06:10:27,474] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:435) [2020-01-28 06:10:27,474] 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) [2020-01-28 06:10:27,475] 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) [2020-01-28 06:10:27,475] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:27,476] 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) [2020-01-28 06:10:27,476] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task coyote_test_console_source-1580191825893-0 using the worker config (org.apache.kafka.connect.runtime.Worker:441) [2020-01-28 06:10:27,477] 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) [2020-01-28 06:10:27,477] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task coyote_test_console_source-1580191825893-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447) [2020-01-28 06:10:27,477] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:27,478] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:441) [2020-01-28 06:10:27,478] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447) [2020-01-28 06:10:27,479] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:497) [2020-01-28 06:10:27,479] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:497) [2020-01-28 06:10:27,480] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:10:27,480] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:10:27,485] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:10:27,485] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:10:27,486] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:10:27,486] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:10:27,489] INFO WorkerSourceTask{id=coyote_test_console_source-1580191825893-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:203) [2020-01-28 06:10:27,489] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860) [2020-01-28 06:10:27,490] INFO WorkerSourceTask{id=logs-broker-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:203) [2020-01-28 06:10:27,587] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:10:27,587] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:10:28,007] WARN [Producer clientId=producer-7] Error while fetching metadata with correlation id 3 : {coyote_cd-1580191825893=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:1031) [2020-01-28 06:10:51,958] INFO Successfully processed removal of connector 'coyote_test_console_source-1580191825893' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:517) [2020-01-28 06:10:51,958] INFO Connector coyote_test_console_source-1580191825893 config removed (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1084) [2020-01-28 06:10:52,461] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238) [2020-01-28 06:10:52,461] INFO Stopping connector logs-broker (org.apache.kafka.connect.runtime.Worker:339) [2020-01-28 06:10:52,461] INFO Stopping task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:599) [2020-01-28 06:10:52,462] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:52,461] INFO Stopping task coyote_test_console_source-1580191825893-0 (org.apache.kafka.connect.runtime.Worker:599) [2020-01-28 06:10:52,461] INFO Stopping connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.Worker:339) [2020-01-28 06:10:52,463] INFO WorkerSourceTask{id=coyote_test_console_source-1580191825893-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:10:52,462] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:10:52,464] INFO WorkerSourceTask{id=coyote_test_console_source-1580191825893-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:10:52,463] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:52,464] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:10:52,464] INFO Stopped connector logs-broker (org.apache.kafka.connect.runtime.Worker:355) [2020-01-28 06:10:52,465] INFO Stopped connector coyote_test_console_source-1580191825893 (org.apache.kafka.connect.runtime.Worker:355) [2020-01-28 06:10:52,468] INFO WorkerSourceTask{id=coyote_test_console_source-1580191825893-0} Finished commitOffsets successfully in 4 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:10:52,468] INFO [Producer clientId=producer-7] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1145) [2020-01-28 06:10:52,470] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 6 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:10:52,470] INFO [Producer clientId=producer-6] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1145) [2020-01-28 06:10:52,478] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268) [2020-01-28 06:10:52,478] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491) [2020-01-28 06:10:52,483] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 6 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455) [2020-01-28 06:10:52,483] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-9cdee0c3-56e5-4ef5-8089-e6f701dcfc21', leaderUrl='http://172.17.0.4:8083/', offset=8, connectorIds=[logs-broker], taskIds=[logs-broker-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216) [2020-01-28 06:10:52,484] INFO Starting connectors and tasks using config offset 8 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850) [2020-01-28 06:10:52,484] INFO Starting connector logs-broker (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904) [2020-01-28 06:10:52,484] INFO Starting task logs-broker-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:864) [2020-01-28 06:10:52,484] INFO Creating task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:397) [2020-01-28 06:10:52,484] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:52,484] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:52,485] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:52,485] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:279) [2020-01-28 06:10:52,485] INFO Creating connector logs-broker of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:236) [2020-01-28 06:10:52,485] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:52,485] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:279) [2020-01-28 06:10:52,486] INFO Instantiated connector logs-broker with version 2.2.2-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:239) [2020-01-28 06:10:52,486] INFO Instantiated task logs-broker-0 with version 2.2.2-L0 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:412) [2020-01-28 06:10:52,486] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:52,486] INFO AbstractConfig values: batch.size = 2000 file = /var/log/broker.log topic = [logs_broker] (org.apache.kafka.common.config.AbstractConfig:279) [2020-01-28 06:10:52,486] 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) [2020-01-28 06:10:52,486] INFO Finished creating connector logs-broker (org.apache.kafka.connect.runtime.Worker:258) [2020-01-28 06:10:52,486] 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) [2020-01-28 06:10:52,487] 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) [2020-01-28 06:10:52,487] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:52,487] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:52,487] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:279) [2020-01-28 06:10:52,487] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:435) [2020-01-28 06:10:52,487] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.file.FileStreamSourceConnector 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 = logs-broker tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279) [2020-01-28 06:10:52,488] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@3bd5dff5 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:158) [2020-01-28 06:10:52,488] 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) [2020-01-28 06:10:52,488] 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) [2020-01-28 06:10:52,488] 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) [2020-01-28 06:10:52,488] INFO AvroDataConfig values: schemas.cache.config = 1000 enhanced.avro.schema.support = false connect.meta.data = true (io.confluent.connect.avro.AvroDataConfig:179) [2020-01-28 06:10:52,488] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:441) [2020-01-28 06:10:52,489] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task logs-broker-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447) [2020-01-28 06:10:52,489] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:497) [2020-01-28 06:10:52,490] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [PLAINTEXT://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) [2020-01-28 06:10:52,493] INFO Kafka version: 2.2.2-L0 (org.apache.kafka.common.utils.AppInfoParser:109) [2020-01-28 06:10:52,493] INFO Kafka commitId: 1d348535a0a747d1 (org.apache.kafka.common.utils.AppInfoParser:110) [2020-01-28 06:10:52,494] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860) [2020-01-28 06:10:52,495] INFO WorkerSourceTask{id=logs-broker-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:203) [2020-01-28 06:10:52,596] INFO Cluster ID: e_QBJbI-SdGvaAXy03-Jyw (org.apache.kafka.clients.Metadata:379) [2020-01-28 06:11:52,495] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:11:52,496] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:11:52,500] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 4 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:12:52,501] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:12:52,501] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:12:52,504] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:13:52,504] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:13:52,505] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:13:52,509] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:14:52,509] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:14:52,510] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:14:52,514] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 4 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:15:52,514] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:15:52,515] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:16:52,515] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:16:52,516] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:17:52,516] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:17:52,516] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:18:52,517] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:18:52,518] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:18:52,523] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 5 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:19:52,523] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:19:52,524] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:20:52,525] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:20:52,526] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:21:52,526] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:21:52,527] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:22:52,527] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:22:52,528] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:23:52,528] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:23:52,528] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:24:52,529] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:24:52,530] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:25:52,530] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:25:52,530] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:26:52,531] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:26:52,531] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:27:52,531] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:27:52,532] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:28:52,532] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:28:52,533] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:28:52,539] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 6 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:29:52,539] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:29:52,540] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:30:52,540] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:30:52,541] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:31:52,542] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:31:52,542] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:32:52,542] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:32:52,543] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:33:52,543] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:33:52,544] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:34:52,545] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:34:52,546] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:35:52,546] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:35:52,546] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:36:52,547] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:36:52,547] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:37:52,548] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:37:52,549] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:38:52,549] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:38:52,550] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:38:52,557] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 7 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:39:52,558] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:39:52,558] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:40:52,558] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:40:52,559] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:41:52,559] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:41:52,560] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:42:52,561] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:42:52,561] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:43:52,562] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:43:52,562] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:44:52,563] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:44:52,563] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:45:52,564] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:45:52,564] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:46:52,564] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:46:52,565] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:47:52,566] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:47:52,566] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:48:52,567] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:48:52,569] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:48:52,577] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 8 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:49:52,577] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:49:52,578] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:50:52,578] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:50:52,579] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:51:52,579] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:51:52,580] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:52:52,580] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:52:52,580] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:53:52,581] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:53:52,581] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:54:52,582] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:54:52,582] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:55:52,583] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:55:52,584] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:56:52,584] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:56:52,585] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:57:52,586] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:57:52,586] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:58:52,587] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:58:52,588] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 06:58:52,695] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 107 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:509) [2020-01-28 06:59:52,695] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 06:59:52,696] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 07:00:52,696] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 07:00:52,696] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 07:01:52,697] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 07:01:52,697] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427) [2020-01-28 07:02:52,698] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:410) [2020-01-28 07:02:52,700] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:427)