curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused curl: (7) Failed to connect to 127.0.0.1 port 8081: Connection refused {} SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/opt/landoop/kafka/share/java/kafka/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/opt/landoop/kafka/share/java/landoop-common/slf4j-log4j12-1.7.26.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] [2021-03-06 06:44:35,402] INFO WorkerInfo values: jvm.args = -Xmx640M, -Xms128M, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -XX:MaxInlineLevel=15, -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=127.0.0.1, -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_275, 25.275-b01 jvm.classpath = /opt/landoop/kafka/share/java/kafka/activation-1.1.1.jar:/opt/landoop/kafka/share/java/kafka/aopalliance-repackaged-2.5.0.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-cli-1.4.jar:/opt/landoop/kafka/share/java/kafka/commons-lang3-3.8.1.jar:/opt/landoop/kafka/share/java/kafka/connect-api-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-basic-auth-extension-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-file-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-json-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-mirror-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-mirror-client-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-runtime-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-transforms-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/hk2-api-2.5.0.jar:/opt/landoop/kafka/share/java/kafka/hk2-locator-2.5.0.jar:/opt/landoop/kafka/share/java/kafka/hk2-utils-2.5.0.jar:/opt/landoop/kafka/share/java/kafka/jackson-annotations-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-core-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-databind-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-dataformat-csv-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-datatype-jdk8-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-base-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-json-provider-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-module-jaxb-annotations-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-module-paranamer-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jackson-module-scala_2.12-2.10.2.jar:/opt/landoop/kafka/share/java/kafka/jakarta.activation-api-1.2.1.jar:/opt/landoop/kafka/share/java/kafka/jakarta.annotation-api-1.3.4.jar:/opt/landoop/kafka/share/java/kafka/jakarta.inject-2.5.0.jar:/opt/landoop/kafka/share/java/kafka/jakarta.ws.rs-api-2.1.5.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/javassist-3.26.0-GA.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/jaxb-api-2.3.0.jar:/opt/landoop/kafka/share/java/kafka/jersey-client-2.28.jar:/opt/landoop/kafka/share/java/kafka/jersey-common-2.28.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-2.28.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-core-2.28.jar:/opt/landoop/kafka/share/java/kafka/jersey-hk2-2.28.jar:/opt/landoop/kafka/share/java/kafka/jersey-media-jaxb-2.28.jar:/opt/landoop/kafka/share/java/kafka/jersey-server-2.28.jar:/opt/landoop/kafka/share/java/kafka/jetty-client-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-continuation-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-http-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-io-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-security-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-server-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlet-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlets-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jetty-util-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/kafka/jopt-simple-5.0.4.jar:/opt/landoop/kafka/share/java/kafka/kafka-clients-2.5.1-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.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-examples-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-scala_2.12-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-test-utils-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-tools-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.12-2.5.1-L0-sources.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.12-2.5.1-L0.jar:/opt/landoop/kafka/share/java/kafka/log4j-1.2.17.jar:/opt/landoop/kafka/share/java/kafka/lz4-java-1.7.1.jar:/opt/landoop/kafka/share/java/kafka/maven-artifact-3.6.3.jar:/opt/landoop/kafka/share/java/kafka/metrics-core-2.2.0.jar:/opt/landoop/kafka/share/java/kafka/netty-buffer-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/netty-codec-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/netty-common-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/netty-handler-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/netty-resolver-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/netty-transport-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/netty-transport-native-epoll-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/netty-transport-native-unix-common-4.1.50.Final.jar:/opt/landoop/kafka/share/java/kafka/osgi-resource-locator-1.0.1.jar:/opt/landoop/kafka/share/java/kafka/paranamer-2.8.jar:/opt/landoop/kafka/share/java/kafka/plexus-utils-3.2.1.jar:/opt/landoop/kafka/share/java/kafka/reflections-0.9.12.jar:/opt/landoop/kafka/share/java/kafka/rocksdbjni-5.18.3.jar:/opt/landoop/kafka/share/java/kafka/scala-collection-compat_2.12-2.1.3.jar:/opt/landoop/kafka/share/java/kafka/scala-java8-compat_2.12-0.9.0.jar:/opt/landoop/kafka/share/java/kafka/scala-library-2.12.10.jar:/opt/landoop/kafka/share/java/kafka/scala-logging_2.12-3.9.2.jar:/opt/landoop/kafka/share/java/kafka/scala-reflect-2.12.10.jar:/opt/landoop/kafka/share/java/kafka/slf4j-api-1.7.30.jar:/opt/landoop/kafka/share/java/kafka/slf4j-log4j12-1.7.30.jar:/opt/landoop/kafka/share/java/kafka/snappy-java-1.1.7.3.jar:/opt/landoop/kafka/share/java/kafka/validation-api-2.0.1.Final.jar:/opt/landoop/kafka/share/java/kafka/zookeeper-3.5.8.jar:/opt/landoop/kafka/share/java/kafka/zookeeper-jute-3.5.8.jar:/opt/landoop/kafka/share/java/kafka/zstd-jni-1.4.4-7.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/animal-sniffer-annotations-1.14.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/annotations-13.0.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/avro-1.9.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/checker-compat-qual-2.0.0.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/classgraph-4.8.21.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/commons-collections-3.2.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/commons-compress-1.19.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/commons-digester-1.8.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/commons-logging-1.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/commons-validator-1.6.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/error_prone_annotations-2.3.4.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/gson-2.8.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/guava-24.1.1-jre.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/handy-uri-templates-2.1.8.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/j2objc-annotations-1.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-annotations-2.10.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-core-2.10.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-databind-2.10.5.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-datatype-guava-2.10.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-datatype-jdk8-2.10.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-datatype-joda-2.10.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-datatype-jsr310-2.10.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-module-parameter-names-2.10.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jakarta.annotation-api-1.3.5.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jakarta.inject-2.6.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jakarta.ws.rs-api-2.1.6.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jersey-common-2.31.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/joda-time-2.9.9.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/json-20190722.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jsr305-1.3.9.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-avro-serializer-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-connect-avro-data-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-connect-json-schema-converter-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-connect-protobuf-converter-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-json-schema-provider-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-json-schema-serializer-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-json-serializer-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-protobuf-provider-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-protobuf-serializer-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-schema-registry-client-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-schema-serializer-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-streams-5.5.3-ccs.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-streams-json-schema-serde-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-streams-protobuf-serde-5.5.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-reflect-1.3.50.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-script-runtime-1.3.50.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-scripting-common-1.3.50.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-scripting-compiler-embeddable-1.3.50.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-scripting-compiler-impl-embeddable-1.3.50.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-scripting-jvm-1.3.50.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-stdlib-1.4.0.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-stdlib-common-1.3.71.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-stdlib-jdk7-1.3.71.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlin-stdlib-jdk8-1.3.71.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlinx-coroutines-core-1.1.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kotlinx-coroutines-core-common-1.1.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/mbknor-jackson-jsonschema_2.12-1.0.39.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/okio-2.5.0.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/org.everit.json.schema-1.12.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/osgi-resource-locator-1.0.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/protobuf-java-3.11.4.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/protobuf-java-util-3.11.4.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/re2j-1.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/rocksdbjni-5.18.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/scala-library-2.12.10.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/swagger-annotations-1.6.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/validation-api-2.0.1.Final.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/wire-runtime-3.2.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/wire-schema-3.2.2.jar:/opt/landoop/kafka/share/java/confluent-common/build-tools-5.5.3.jar:/opt/landoop/kafka/share/java/confluent-common/common-config-5.5.3.jar:/opt/landoop/kafka/share/java/confluent-common/common-metrics-5.5.3.jar:/opt/landoop/kafka/share/java/confluent-common/common-utils-5.5.3.jar:/opt/landoop/kafka/share/java/confluent-common/slf4j-api-1.7.26.jar:/opt/landoop/kafka/share/java/landoop-common/aggdesigner-algorithm-6.0.jar:/opt/landoop/kafka/share/java/landoop-common/annotations-13.0.jar:/opt/landoop/kafka/share/java/landoop-common/antlr4-runtime-4.7.jar:/opt/landoop/kafka/share/java/landoop-common/aopalliance-repackaged-2.6.1.jar:/opt/landoop/kafka/share/java/landoop-common/asm-7.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-analysis-7.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-commons-7.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-tree-7.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.9.2.jar:/opt/landoop/kafka/share/java/landoop-common/avro4s-core_2.12-1.7.0.jar:/opt/landoop/kafka/share/java/landoop-common/avro4s-macros_2.12-1.7.0.jar:/opt/landoop/kafka/share/java/landoop-common/calcite-core-1.12.0.jar:/opt/landoop/kafka/share/java/landoop-common/calcite-linq4j-1.8.0.jar:/opt/landoop/kafka/share/java/landoop-common/classgraph-4.8.21.jar:/opt/landoop/kafka/share/java/landoop-common/classmate-1.3.4.jar:/opt/landoop/kafka/share/java/landoop-common/common-config-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-metrics-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-utils-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/commons-collections-3.2.2.jar:/opt/landoop/kafka/share/java/landoop-common/commons-compiler-2.7.6.jar:/opt/landoop/kafka/share/java/landoop-common/commons-compress-1.19.jar:/opt/landoop/kafka/share/java/landoop-common/commons-dbcp-1.4.jar:/opt/landoop/kafka/share/java/landoop-common/commons-digester-1.8.1.jar:/opt/landoop/kafka/share/java/landoop-common/commons-lang-2.4.jar:/opt/landoop/kafka/share/java/landoop-common/commons-lang3-3.2.1.jar:/opt/landoop/kafka/share/java/landoop-common/commons-logging-1.2.jar:/opt/landoop/kafka/share/java/landoop-common/commons-pool-1.5.4.jar:/opt/landoop/kafka/share/java/landoop-common/commons-validator-1.6.jar:/opt/landoop/kafka/share/java/landoop-common/connect-api-2.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/connect-json-2.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/error_prone_annotations-2.3.4.jar:/opt/landoop/kafka/share/java/landoop-common/gson-2.8.6.jar:/opt/landoop/kafka/share/java/landoop-common/guava-19.0.jar:/opt/landoop/kafka/share/java/landoop-common/handy-uri-templates-2.1.8.jar:/opt/landoop/kafka/share/java/landoop-common/hibernate-validator-6.0.17.Final.jar:/opt/landoop/kafka/share/java/landoop-common/hk2-api-2.6.1.jar:/opt/landoop/kafka/share/java/landoop-common/hk2-locator-2.6.1.jar:/opt/landoop/kafka/share/java/landoop-common/hk2-utils-2.6.1.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-dataformat-yaml-2.4.5.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-datatype-guava-2.10.2.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-datatype-joda-2.4.5.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-datatype-jsr310-2.10.2.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-module-parameter-names-2.10.2.jar:/opt/landoop/kafka/share/java/landoop-common/jakarta.annotation-api-1.3.5.jar:/opt/landoop/kafka/share/java/landoop-common/jakarta.el-3.0.2.jar:/opt/landoop/kafka/share/java/landoop-common/jakarta.el-api-3.0.3.jar:/opt/landoop/kafka/share/java/landoop-common/jakarta.inject-2.6.1.jar:/opt/landoop/kafka/share/java/landoop-common/jakarta.validation-api-2.0.2.jar:/opt/landoop/kafka/share/java/landoop-common/jakarta.ws.rs-api-2.1.6.jar:/opt/landoop/kafka/share/java/landoop-common/janino-2.7.6.jar:/opt/landoop/kafka/share/java/landoop-common/javassist-3.25.0-GA.jar:/opt/landoop/kafka/share/java/landoop-common/javax-websocket-client-impl-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/javax-websocket-server-impl-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/javax.annotation-api-1.3.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.3.2.Final.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-bean-validation-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-client-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-common-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-container-servlet-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-container-servlet-core-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-hk2-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-media-jaxb-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-server-2.30.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-annotations-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jaas-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jmx-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jndi-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-plus-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-webapp-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-xml-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/joda-time-2.10.2.jar:/opt/landoop/kafka/share/java/landoop-common/json-20190722.jar:/opt/landoop/kafka/share/java/landoop-common/json-sql_2.12-2.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-ast_2.12-3.6.7.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-core_2.12-3.6.7.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-jackson_2.12-3.6.7.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-native_2.12-3.6.7.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-scalap_2.12-3.6.7.jar:/opt/landoop/kafka/share/java/landoop-common/jsr305-3.0.1.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-avro-serializer-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-clients-5.5.0-ccs.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-avro-converter-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-avro-data-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-smt_2.12-2.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-json-schema-provider-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-protobuf-provider-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-registry-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-registry-client-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-serializer-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka_2.12-5.5.0-ccs.jar:/opt/landoop/kafka/share/java/landoop-common/kcql-2.8.7.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-reflect-1.3.50.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-script-runtime-1.3.50.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-scripting-common-1.3.50.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-scripting-compiler-embeddable-1.3.50.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-scripting-compiler-impl-embeddable-1.3.50.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-scripting-jvm-1.3.50.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-stdlib-1.3.61.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-stdlib-common-1.3.61.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-stdlib-jdk7-1.3.61.jar:/opt/landoop/kafka/share/java/landoop-common/kotlin-stdlib-jdk8-1.3.61.jar:/opt/landoop/kafka/share/java/landoop-common/kotlinx-coroutines-core-1.1.1.jar:/opt/landoop/kafka/share/java/landoop-common/macro-compat_2.12-1.1.1.jar:/opt/landoop/kafka/share/java/landoop-common/mbknor-jackson-jsonschema_2.12-1.0.36.jar:/opt/landoop/kafka/share/java/landoop-common/netty-buffer-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/netty-codec-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/netty-common-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/netty-handler-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/netty-resolver-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/netty-transport-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/netty-transport-native-epoll-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/netty-transport-native-unix-common-4.1.45.Final.jar:/opt/landoop/kafka/share/java/landoop-common/okio-jvm-2.4.3.jar:/opt/landoop/kafka/share/java/landoop-common/org.everit.json.schema-1.12.1.jar:/opt/landoop/kafka/share/java/landoop-common/osgi-resource-locator-1.0.3.jar:/opt/landoop/kafka/share/java/landoop-common/protobuf-java-3.11.4.jar:/opt/landoop/kafka/share/java/landoop-common/protobuf-java-util-3.11.4.jar:/opt/landoop/kafka/share/java/landoop-common/re2j-1.3.jar:/opt/landoop/kafka/share/java/landoop-common/rest-utils-5.5.0.jar:/opt/landoop/kafka/share/java/landoop-common/shapeless_2.12-2.3.2.jar:/opt/landoop/kafka/share/java/landoop-common/slf4j-log4j12-1.7.26.jar:/opt/landoop/kafka/share/java/landoop-common/snakeyaml-1.12.jar:/opt/landoop/kafka/share/java/landoop-common/sql-core_2.12-2.0.jar:/opt/landoop/kafka/share/java/landoop-common/swagger-annotations-1.5.22.jar:/opt/landoop/kafka/share/java/landoop-common/swagger-core-1.5.3.jar:/opt/landoop/kafka/share/java/landoop-common/swagger-models-1.5.3.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-api-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-client-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-common-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-server-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-servlet-9.4.24.v20191120.jar:/opt/landoop/kafka/share/java/landoop-common/wire-runtime-jvm-3.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/wire-schema-jvm-3.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/zkclient-0.11.jar:/opt/landoop/kafka/share/java/landoop-common/zookeeper-3.5.7.jar:/opt/landoop/kafka/share/java/landoop-common/zookeeper-jute-3.5.7.jar os.spec = Linux, amd64, 3.10.0-693.17.1.el7.x86_64 os.vcpus = 32 (org.apache.kafka.connect.runtime.WorkerInfo:71) [2021-03-06 06:44:35,408] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:90) [2021-03-06 06:44:35,432] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-aws-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:40,211] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-aws-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:40,212] INFO Added plugin 'io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,212] INFO Added plugin 'io.lenses.streamreactor.connect.aws.s3.source.S3SourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,212] INFO Added plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,212] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,212] INFO Added plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,212] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,212] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,213] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:40,304] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-azure-documentdb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:42,357] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-azure-documentdb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:42,357] INFO Added plugin 'com.datamountaineer.streamreactor.connect.azure.documentdb.sink.DocumentDbSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:42,373] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-blockchain (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:44,155] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-blockchain/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:44,156] INFO Added plugin 'com.datamountaineer.streamreactor.connect.blockchain.source.BlockchainSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:44,169] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-bloomberg (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:45,790] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-bloomberg/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:45,791] INFO Added plugin 'com.datamountaineer.streamreactor.connect.bloomberg.BloombergSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:45,806] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-cassandra (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:47,524] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-cassandra/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:47,525] INFO Added plugin 'com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:47,525] INFO Added plugin 'com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:47,537] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-coap (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:49,613] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-coap/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:49,614] INFO Added plugin 'com.datamountaineer.streamreactor.connect.coap.source.CoapSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:49,614] INFO Added plugin 'com.datamountaineer.streamreactor.connect.coap.sink.CoapSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:49,629] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-elastic6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:51,934] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-elastic6/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:51,935] INFO Added plugin 'com.datamountaineer.streamreactor.connect.elastic6.ElasticSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:51,950] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-elastic7 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:54,205] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-elastic7/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:54,205] INFO Added plugin 'com.datamountaineer.streamreactor.connect.elastic7.ElasticSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:54,222] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-ftp (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:55,971] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-ftp/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:55,972] INFO Added plugin 'com.datamountaineer.streamreactor.connect.ftp.source.FtpSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:55,988] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-hazelcast (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:44:58,237] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-hazelcast/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:44:58,238] INFO Added plugin 'com.datamountaineer.streamreactor.connect.hazelcast.sink.HazelCastSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:44:58,253] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-hbase (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:00,668] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-hbase/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:00,668] INFO Added plugin 'com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:00,685] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-hive (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:06,167] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-hive/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:06,167] INFO Added plugin 'com.landoop.streamreactor.connect.hive.sink.HiveSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:06,167] INFO Added plugin 'com.landoop.streamreactor.connect.hive.source.HiveSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:06,204] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-influxdb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:07,980] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-influxdb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:07,980] INFO Added plugin 'com.datamountaineer.streamreactor.connect.influx.InfluxSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:07,996] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-jms (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:10,226] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-jms/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:10,227] INFO Added plugin 'com.datamountaineer.streamreactor.connect.jms.source.JMSSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:10,227] INFO Added plugin 'com.datamountaineer.streamreactor.connect.jms.sink.JMSSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:10,227] INFO Added plugin 'com.datamountaineer.streamreactor.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:10,244] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-kudu (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:12,233] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-kudu/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:12,233] INFO Added plugin 'com.datamountaineer.streamreactor.connect.kudu.sink.KuduSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:12,247] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:14,103] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:14,104] INFO Added plugin 'com.datamountaineer.streamreactor.connect.mongodb.sink.MongoSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:14,123] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-mqtt (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:16,245] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-mqtt/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:16,245] INFO Added plugin 'com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:16,245] INFO Added plugin 'com.datamountaineer.streamreactor.connect.mqtt.sink.MqttSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:16,261] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-pulsar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:21,485] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-pulsar/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:21,486] INFO Added plugin 'com.datamountaineer.streamreactor.connect.pulsar.source.PulsarSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:21,486] INFO Added plugin 'com.datamountaineer.streamreactor.connect.pulsar.sink.PulsarSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:21,504] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-redis (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:23,070] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-redis/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:23,070] INFO Added plugin 'com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:23,089] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-rethink (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:25,148] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-rethink/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:25,148] INFO Added plugin 'com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:25,148] INFO Added plugin 'com.datamountaineer.streamreactor.connect.rethink.source.ReThinkSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:25,164] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-secret-provider (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:31,130] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-secret-provider/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:31,130] INFO Added plugin 'io.lenses.connect.secrets.providers.AzureSecretProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:31,130] INFO Added plugin 'io.lenses.connect.secrets.providers.VaultSecretProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:31,130] INFO Added plugin 'io.lenses.connect.secrets.providers.AWSSecretProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:31,131] INFO Added plugin 'io.lenses.connect.secrets.providers.Aes256DecodingProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:31,132] INFO Loading plugin from: /var/run/connect/connectors/stream-reactor/kafka-connect-voltdb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:33,050] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/stream-reactor/kafka-connect-voltdb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:33,050] INFO Added plugin 'com.datamountaineer.streamreactor.connect.voltdb.VoltSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:33,069] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-couchbase (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:33,789] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-couchbase/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:33,789] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:33,790] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:33,792] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:34,029] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:34,030] INFO Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,030] INFO Added plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,030] INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,030] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,030] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,030] INFO Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,030] INFO Added plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,031] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,032] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-mysql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:34,295] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-mysql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:34,296] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,302] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-postgres (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:34,500] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-postgres/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:34,501] INFO Added plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,509] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-debezium-sqlserver (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:34,644] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-debezium-sqlserver/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:34,645] INFO Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,666] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:34,902] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:34,903] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:34,904] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-hdfs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:37,095] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-hdfs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:37,095] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:37,095] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:37,095] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:37,095] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:37,127] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:37,258] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:37,258] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:37,259] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:37,273] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:38,331] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:38,331] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:38,351] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-splunk (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:38,685] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-splunk/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:38,686] INFO Added plugin 'com.splunk.kafka.connect.SplunkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:38,686] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:38,686] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:38,688] INFO Loading plugin from: /var/run/connect/connectors/third-party/kafka-connect-twitter (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:239) [2021-03-06 06:45:39,848] INFO Registered loader: PluginClassLoader{pluginLocation=file:/var/run/connect/connectors/third-party/kafka-connect-twitter/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:39,848] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:39,848] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,104] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:262) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,105] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'io.confluent.connect.protobuf.ProtobufConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,106] INFO Added plugin 'io.confluent.connect.json.JsonSchemaConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,107] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,108] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,108] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,108] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,108] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,108] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,108] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,109] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,109] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,109] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,109] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,109] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,109] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,109] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:191) [2021-03-06 06:45:42,111] INFO Added aliases 'CouchbaseSinkConnector' and 'CouchbaseSink' to plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,112] INFO Added aliases 'CouchbaseSourceConnector' and 'CouchbaseSource' to plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,112] INFO Added aliases 'DocumentDbSinkConnector' and 'DocumentDbSink' to plugin 'com.datamountaineer.streamreactor.connect.azure.documentdb.sink.DocumentDbSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,112] INFO Added aliases 'BlockchainSourceConnector' and 'BlockchainSource' to plugin 'com.datamountaineer.streamreactor.connect.blockchain.source.BlockchainSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,113] INFO Added aliases 'BloombergSourceConnector' and 'BloombergSource' to plugin 'com.datamountaineer.streamreactor.connect.bloomberg.BloombergSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,113] INFO Added aliases 'CassandraSinkConnector' and 'CassandraSink' to plugin 'com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,113] INFO Added aliases 'CassandraSourceConnector' and 'CassandraSource' to plugin 'com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,113] INFO Added aliases 'CoapSinkConnector' and 'CoapSink' to plugin 'com.datamountaineer.streamreactor.connect.coap.sink.CoapSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,114] INFO Added aliases 'CoapSourceConnector' and 'CoapSource' to plugin 'com.datamountaineer.streamreactor.connect.coap.source.CoapSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,114] INFO Added aliases 'FtpSourceConnector' and 'FtpSource' to plugin 'com.datamountaineer.streamreactor.connect.ftp.source.FtpSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,114] INFO Added aliases 'HazelCastSinkConnector' and 'HazelCastSink' to plugin 'com.datamountaineer.streamreactor.connect.hazelcast.sink.HazelCastSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,114] INFO Added aliases 'HbaseSinkConnector' and 'HbaseSink' to plugin 'com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,115] INFO Added aliases 'InfluxSinkConnector' and 'InfluxSink' to plugin 'com.datamountaineer.streamreactor.connect.influx.InfluxSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,115] INFO Added aliases 'JMSSinkConnector' and 'JMSSink' to plugin 'com.datamountaineer.streamreactor.connect.jms.sink.JMSSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,115] INFO Added aliases 'JMSSourceConnector' and 'JMSSource' to plugin 'com.datamountaineer.streamreactor.connect.jms.source.JMSSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,115] INFO Added aliases 'KuduSinkConnector' and 'KuduSink' to plugin 'com.datamountaineer.streamreactor.connect.kudu.sink.KuduSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,115] INFO Added aliases 'MongoSinkConnector' and 'MongoSink' to plugin 'com.datamountaineer.streamreactor.connect.mongodb.sink.MongoSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,116] INFO Added aliases 'MqttSinkConnector' and 'MqttSink' to plugin 'com.datamountaineer.streamreactor.connect.mqtt.sink.MqttSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,116] INFO Added aliases 'MqttSourceConnector' and 'MqttSource' to plugin 'com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,116] INFO Added aliases 'PulsarSinkConnector' and 'PulsarSink' to plugin 'com.datamountaineer.streamreactor.connect.pulsar.sink.PulsarSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,116] INFO Added aliases 'PulsarSourceConnector' and 'PulsarSource' to plugin 'com.datamountaineer.streamreactor.connect.pulsar.source.PulsarSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,117] INFO Added aliases 'RedisSinkConnector' and 'RedisSink' to plugin 'com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,117] INFO Added aliases 'ReThinkSinkConnector' and 'ReThinkSink' to plugin 'com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,118] INFO Added aliases 'ReThinkSourceConnector' and 'ReThinkSource' to plugin 'com.datamountaineer.streamreactor.connect.rethink.source.ReThinkSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,118] INFO Added aliases 'VoltSinkConnector' and 'VoltSink' to plugin 'com.datamountaineer.streamreactor.connect.voltdb.VoltSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,118] INFO Added aliases 'TwitterSinkConnector' and 'TwitterSink' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,119] INFO Added aliases 'TwitterSourceConnector' and 'TwitterSource' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,119] INFO Added aliases 'HiveSinkConnector' and 'HiveSink' to plugin 'com.landoop.streamreactor.connect.hive.sink.HiveSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,120] INFO Added aliases 'HiveSourceConnector' and 'HiveSource' to plugin 'com.landoop.streamreactor.connect.hive.source.HiveSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,120] INFO Added aliases 'SplunkSinkConnector' and 'SplunkSink' to plugin 'com.splunk.kafka.connect.SplunkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,121] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,121] INFO Added aliases 'HdfsSinkConnector' and 'HdfsSink' to plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,121] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,121] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,122] INFO Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,122] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,122] INFO Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,122] INFO Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,123] INFO Added aliases 'S3SourceConnector' and 'S3Source' to plugin 'io.lenses.streamreactor.connect.aws.s3.source.S3SourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,123] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,123] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,123] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,124] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,124] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,124] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,124] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,124] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'JsonResilientConverter' and 'JsonResilient' to plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'JsonSchemaConverter' and 'JsonSchema' to plugin 'io.confluent.connect.json.JsonSchemaConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'ProtobufConverter' and 'Protobuf' to plugin 'io.confluent.connect.protobuf.ProtobufConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,125] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'JsonResilientConverter' and 'JsonResilient' to plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,126] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,127] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,127] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,127] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,127] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,127] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,127] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,128] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,128] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,128] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,129] INFO Added alias 'Transformation' to plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,129] INFO Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,129] INFO Added alias 'UnwrapFromMongoDbEnvelope' to plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,129] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,130] INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,130] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,130] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,131] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,133] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,133] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,133] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:416) [2021-03-06 06:45:42,134] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,134] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,134] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:419) [2021-03-06 06:45:42,373] INFO DistributedConfig values: access.control.allow.methods = GET,POST,PUT,DELETE,OPTIONS access.control.allow.origin = * admin.listeners = null bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] client.dns.lookup = default client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = connect-configs connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = None group.id = connect-fast-data header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter heartbeat.interval.ms = 3000 inter.worker.key.generation.algorithm = HmacSHA256 inter.worker.key.size = null inter.worker.key.ttl.ms = 3600000 inter.worker.signature.algorithm = HmacSHA256 inter.worker.verification.algorithms = [HmacSHA256] 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 scheduled.rebalance.max.delay.ms = 300000 security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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 topic.tracking.allow.reset = true topic.tracking.enable = true 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:347) [2021-03-06 06:45:42,377] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43) [2021-03-06 06:45:42,382] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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 = 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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:42,478] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,478] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,478] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,479] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,479] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,479] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,479] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,479] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,479] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,479] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,480] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,480] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,480] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,480] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,480] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,480] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,480] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:42,481] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:42,481] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:42,482] INFO Kafka startTimeMs: 1615013142481 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:42,892] INFO Kafka cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.connect.util.ConnectUtils:59) [2021-03-06 06:45:42,920] INFO Logging initialized @69622ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:169) [2021-03-06 06:45:42,997] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:131) [2021-03-06 06:45:42,998] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:203) [2021-03-06 06:45:43,007] INFO jetty-9.4.24.v20191120; built: 2019-11-20T21:37:49.771Z; git: 363d5f2df3a8a28de40604320230664b9c793c16; jvm 1.8.0_275-b01 (org.eclipse.jetty.server.Server:359) [2021-03-06 06:45:43,048] INFO Started http_8083@4f36a620{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:330) [2021-03-06 06:45:43,049] INFO Started @69751ms (org.eclipse.jetty.server.Server:399) [2021-03-06 06:45:43,076] INFO Advertised URI: http://172.17.0.2:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:365) [2021-03-06 06:45:43,076] INFO REST server listening at http://172.17.0.2:8083/, advertising URL http://172.17.0.2:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:218) [2021-03-06 06:45:43,077] INFO Advertised URI: http://172.17.0.2:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:365) [2021-03-06 06:45:43,077] INFO REST admin endpoints at http://172.17.0.2:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:219) [2021-03-06 06:45:43,077] INFO Advertised URI: http://172.17.0.2:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:365) [2021-03-06 06:45:43,084] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45) [2021-03-06 06:45:43,097] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,097] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,097] INFO Kafka startTimeMs: 1615013143097 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,287] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2021-03-06 06:45:43,289] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2021-03-06 06:45:43,350] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,351] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,351] INFO Kafka startTimeMs: 1615013143350 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,354] INFO Kafka Connect distributed worker initialization took 67946ms (org.apache.kafka.connect.cli.ConnectDistributed:128) [2021-03-06 06:45:43,354] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:51) [2021-03-06 06:45:43,356] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:223) [2021-03-06 06:45:43,357] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:286) [2021-03-06 06:45:43,358] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:184) [2021-03-06 06:45:43,358] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108) [2021-03-06 06:45:43,359] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:127) [2021-03-06 06:45:43,359] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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 = 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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,366] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,366] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,366] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,366] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,366] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,367] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,367] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,367] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,367] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,367] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,368] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,368] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,368] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,368] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,368] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,369] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,369] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,369] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,370] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,370] INFO Kafka startTimeMs: 1615013143369 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,415] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:240) [2021-03-06 06:45:43,526] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:333) [2021-03-06 06:45:43,526] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:338) [2021-03-06 06:45:43,528] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:140) [2021-03-06 06:45:43,618] INFO Created topic (name=connect-offsets, numPartitions=25, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at PLAINTEXT://127.0.0.1:9092 (org.apache.kafka.connect.util.TopicAdmin:230) [2021-03-06 06:45:43,632] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = producer-1 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 metadata.max.idle.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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,662] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,662] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,662] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,662] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,662] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,663] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,664] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,664] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,664] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,664] INFO Kafka startTimeMs: 1615013143664 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,675] INFO [Producer clientId=producer-1] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:43,677] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = 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 group.instance.id = null 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,714] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,714] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,714] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,714] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,714] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,714] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,715] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,716] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,716] INFO Kafka startTimeMs: 1615013143715 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,724] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:43,755] INFO [Consumer clientId=consumer-connect-fast-data-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:1128) [2021-03-06 06:45:43,760] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,761] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,762] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,763] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,763] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,763] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,763] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,763] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-offsets-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,800] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-10 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,801] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-8 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,802] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-14 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,802] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-12 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,802] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,802] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,802] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-6 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,802] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,803] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-24 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,803] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-18 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,803] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-16 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,803] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-22 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,803] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-20 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,804] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-9 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,804] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-7 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,804] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-13 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,804] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-11 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,805] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,805] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-5 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,805] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,805] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-23 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,805] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-17 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,805] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-15 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,806] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-21 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,806] INFO [Consumer clientId=consumer-connect-fast-data-1, groupId=connect-fast-data] Resetting offset for partition connect-offsets-19 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,807] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:161) [2021-03-06 06:45:43,807] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:163) [2021-03-06 06:45:43,807] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110) [2021-03-06 06:45:43,811] INFO Worker started (org.apache.kafka.connect.runtime.Worker:191) [2021-03-06 06:45:43,811] INFO Starting KafkaBasedLog with topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:127) [2021-03-06 06:45:43,811] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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 = 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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,814] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,814] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,815] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,815] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,816] INFO Kafka startTimeMs: 1615013143815 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,879] INFO Created topic (name=connect-statuses, numPartitions=5, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at PLAINTEXT://127.0.0.1:9092 (org.apache.kafka.connect.util.TopicAdmin:230) [2021-03-06 06:45:43,882] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = producer-2 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 metadata.max.idle.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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,886] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,887] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,888] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,888] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,888] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,888] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,888] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,888] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,888] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,891] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,892] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,892] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,892] INFO Kafka startTimeMs: 1615013143892 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,893] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = 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 group.instance.id = null 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,898] INFO [Producer clientId=producer-2] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:43,900] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,901] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,901] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,901] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,901] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,901] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,902] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,902] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,903] INFO Kafka startTimeMs: 1615013143902 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,906] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:43,909] INFO [Consumer clientId=consumer-connect-fast-data-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:1128) [2021-03-06 06:45:43,910] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-statuses-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,910] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-statuses-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,910] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-statuses-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,910] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-statuses-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,910] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-statuses-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,916] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,917] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,917] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,917] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,917] INFO [Consumer clientId=consumer-connect-fast-data-2, groupId=connect-fast-data] Resetting offset for partition connect-statuses-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,918] INFO Finished reading KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:161) [2021-03-06 06:45:43,918] INFO Started KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:163) [2021-03-06 06:45:43,921] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:262) [2021-03-06 06:45:43,922] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:127) [2021-03-06 06:45:43,923] INFO AdminClientConfig values: bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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 = 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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,925] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,925] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,925] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,925] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,926] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,927] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,927] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,927] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2021-03-06 06:45:43,927] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,927] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,927] INFO Kafka startTimeMs: 1615013143927 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,961] INFO Created topic (name=connect-configs, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at PLAINTEXT://127.0.0.1:9092 (org.apache.kafka.connect.util.TopicAdmin:230) [2021-03-06 06:45:43,964] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = producer-3 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 metadata.max.idle.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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,969] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,970] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,970] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,970] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,970] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,970] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,970] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,971] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,972] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,972] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2021-03-06 06:45:43,972] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,972] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,973] INFO Kafka startTimeMs: 1615013143972 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,973] INFO [Producer clientId=producer-3] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:43,974] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = 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 group.instance.id = null 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:43,979] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,979] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,979] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,979] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,979] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'access.control.allow.methods' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'access.control.allow.origin' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'jmx.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,980] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,981] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2021-03-06 06:45:43,981] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:43,981] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:43,981] INFO Kafka startTimeMs: 1615013143981 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:43,985] INFO [Consumer clientId=consumer-connect-fast-data-3, groupId=connect-fast-data] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:43,989] INFO [Consumer clientId=consumer-connect-fast-data-3, groupId=connect-fast-data] Subscribed to partition(s): connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1128) [2021-03-06 06:45:43,990] INFO [Consumer clientId=consumer-connect-fast-data-3, groupId=connect-fast-data] Seeking to EARLIEST offset of partition connect-configs-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:601) [2021-03-06 06:45:43,996] INFO [Consumer clientId=consumer-connect-fast-data-3, groupId=connect-fast-data] Resetting offset for partition connect-configs-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:397) [2021-03-06 06:45:43,996] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:161) [2021-03-06 06:45:43,996] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:163) [2021-03-06 06:45:43,996] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:277) [2021-03-06 06:45:43,997] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:290) [2021-03-06 06:45:44,012] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:44,013] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Discovered group coordinator 1bbe6d6e72ae:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797) [2021-03-06 06:45:44,017] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225) [2021-03-06 06:45:44,018] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) Mar 06, 2021 6:45:44 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. Mar 06, 2021 6:45:44 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. Mar 06, 2021 6:45:44 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. Mar 06, 2021 6:45:44 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource 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.LoggingResource will be ignored. [2021-03-06 06:45:44,031] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455) [2021-03-06 06:45:44,032] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) [2021-03-06 06:45:44,207] INFO HV000001: Hibernate Validator 6.0.17.Final (org.hibernate.validator.internal.util.Version:21) Mar 06, 2021 6:45:44 AM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. 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. [2021-03-06 06:45:44,794] INFO Started o.e.j.s.ServletContextHandler@70bad342{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:825) [2021-03-06 06:45:44,795] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:313) [2021-03-06 06:45:44,795] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57) [2021-03-06 06:45:45,071] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503) [2021-03-06 06:45:45,074] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-643e33fb-8a83-4c82-a93e-a455d1a4d977', leaderUrl='http://172.17.0.2:8083/', offset=-1, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1600) [2021-03-06 06:45:45,074] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1143) [2021-03-06 06:45:45,075] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171) [2021-03-06 06:45:45,178] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1486) [2021-03-06 06:45:46,698] INFO JVM Runtime does not support Modules (org.eclipse.jetty.util.TypeUtil:201) [2021-03-06 06:45:52,045] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:347) [2021-03-06 06:45:52,053] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Connector logs-broker config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1442) [2021-03-06 06:45:52,054] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225) [2021-03-06 06:45:52,054] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) [2021-03-06 06:45:52,064] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503) [2021-03-06 06:45:52,064] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Joined group at generation 2 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-643e33fb-8a83-4c82-a93e-a455d1a4d977', leaderUrl='http://172.17.0.2:8083/', offset=2, connectorIds=[logs-broker], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1600) [2021-03-06 06:45:52,065] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connectors and tasks using config offset 2 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1143) [2021-03-06 06:45:52,066] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connector logs-broker (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1225) [2021-03-06 06:45:52,072] 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:347) [2021-03-06 06:45:52,074] 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:347) [2021-03-06 06:45:52,074] INFO Creating connector logs-broker of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:253) [2021-03-06 06:45:52,079] INFO Instantiated connector logs-broker with version 2.5.1-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:256) [2021-03-06 06:45:52,080] INFO AbstractConfig values: batch.size = 2000 file = /var/log/broker.log topic = [logs_broker] (org.apache.kafka.common.config.AbstractConfig:347) [2021-03-06 06:45:52,087] INFO Finished creating connector logs-broker (org.apache.kafka.connect.runtime.Worker:275) [2021-03-06 06:45:52,089] 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:347) [2021-03-06 06:45:52,089] 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:347) [2021-03-06 06:45:52,566] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Tasks [logs-broker-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1457) [2021-03-06 06:45:53,067] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171) [2021-03-06 06:45:53,070] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Handling task config update by restarting tasks [] (org.apache.kafka.connect.runtime.distributed.DistributedHerder:585) [2021-03-06 06:45:53,071] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225) [2021-03-06 06:45:53,071] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) [2021-03-06 06:45:53,078] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 3 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503) [2021-03-06 06:45:53,079] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Joined group at generation 3 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-643e33fb-8a83-4c82-a93e-a455d1a4d977', leaderUrl='http://172.17.0.2:8083/', offset=4, connectorIds=[logs-broker], taskIds=[logs-broker-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1600) [2021-03-06 06:45:53,081] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connectors and tasks using config offset 4 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1143) [2021-03-06 06:45:53,083] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting task logs-broker-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1185) [2021-03-06 06:45:53,083] INFO Creating task logs-broker-0 (org.apache.kafka.connect.runtime.Worker:421) [2021-03-06 06:45:53,085] 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:347) [2021-03-06 06:45:53,086] 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:347) [2021-03-06 06:45:53,089] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:347) [2021-03-06 06:45:53,089] INFO Instantiated task logs-broker-0 with version 2.5.1-L0 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:436) [2021-03-06 06:45:53,110] INFO AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2021-03-06 06:45:53,197] INFO KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2021-03-06 06:45:53,202] INFO KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2021-03-06 06:45:53,246] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 (io.confluent.connect.avro.AvroDataConfig:347) [2021-03-06 06:45:53,246] 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:449) [2021-03-06 06:45:53,246] INFO AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2021-03-06 06:45:53,247] INFO KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2021-03-06 06:45:53,247] INFO KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2021-03-06 06:45:53,247] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 (io.confluent.connect.avro.AvroDataConfig:347) [2021-03-06 06:45:53,247] 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:455) [2021-03-06 06:45:53,248] 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:462) [2021-03-06 06:45:53,256] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:516) [2021-03-06 06:45:53,261] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = connector-producer-logs-broker-0 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 metadata.max.idle.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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:45:53,265] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:45:53,265] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:45:53,265] INFO Kafka startTimeMs: 1615013153265 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:45:53,274] INFO [Producer clientId=connector-producer-logs-broker-0] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:45:53,280] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171) [2021-03-06 06:45:53,283] INFO WorkerSourceTask{id=logs-broker-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:216) [2021-03-06 06:45:53,638] WARN [Producer clientId=connector-producer-logs-broker-0] Error while fetching metadata with correlation id 3 : {logs_broker=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:1077) [2021-03-06 06:46:36,763] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:347) [2021-03-06 06:46:36,773] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Connector coyote_test_console_source-1615013196744 config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1442) [2021-03-06 06:46:37,275] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225) [2021-03-06 06:46:37,276] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) [2021-03-06 06:46:37,288] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 4 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503) [2021-03-06 06:46:37,289] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Joined group at generation 4 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-643e33fb-8a83-4c82-a93e-a455d1a4d977', leaderUrl='http://172.17.0.2:8083/', offset=5, connectorIds=[coyote_test_console_source-1615013196744, logs-broker], taskIds=[logs-broker-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1600) [2021-03-06 06:46:37,290] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connectors and tasks using config offset 5 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1143) [2021-03-06 06:46:37,291] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connector coyote_test_console_source-1615013196744 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1225) [2021-03-06 06:46:37,293] 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-1615013196744 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2021-03-06 06:46:37,293] 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-1615013196744 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2021-03-06 06:46:37,294] INFO Creating connector coyote_test_console_source-1615013196744 of type org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:253) [2021-03-06 06:46:37,296] INFO Instantiated connector coyote_test_console_source-1615013196744 with version 2.5.1-L0 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:256) [2021-03-06 06:46:37,296] INFO AbstractConfig values: batch.size = 2000 file = /etc/fstab topic = [coyote_cd-1615013196744] (org.apache.kafka.common.config.AbstractConfig:347) [2021-03-06 06:46:37,298] INFO Finished creating connector coyote_test_console_source-1615013196744 (org.apache.kafka.connect.runtime.Worker:275) [2021-03-06 06:46:37,299] 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-1615013196744 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2021-03-06 06:46:37,299] 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-1615013196744 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2021-03-06 06:46:38,286] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Tasks [coyote_test_console_source-1615013196744-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1457) [2021-03-06 06:46:38,788] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171) [2021-03-06 06:46:38,790] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Handling task config update by restarting tasks [] (org.apache.kafka.connect.runtime.distributed.DistributedHerder:585) [2021-03-06 06:46:38,790] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225) [2021-03-06 06:46:38,790] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) [2021-03-06 06:46:38,796] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 5 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503) [2021-03-06 06:46:38,797] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Joined group at generation 5 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-643e33fb-8a83-4c82-a93e-a455d1a4d977', leaderUrl='http://172.17.0.2:8083/', offset=7, connectorIds=[coyote_test_console_source-1615013196744, logs-broker], taskIds=[coyote_test_console_source-1615013196744-0, logs-broker-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1600) [2021-03-06 06:46:38,797] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connectors and tasks using config offset 7 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1143) [2021-03-06 06:46:38,798] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting task coyote_test_console_source-1615013196744-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1185) [2021-03-06 06:46:38,799] INFO Creating task coyote_test_console_source-1615013196744-0 (org.apache.kafka.connect.runtime.Worker:421) [2021-03-06 06:46:38,801] 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-1615013196744 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2021-03-06 06:46:38,801] 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-1615013196744 tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2021-03-06 06:46:38,801] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:347) [2021-03-06 06:46:38,802] INFO Instantiated task coyote_test_console_source-1615013196744-0 with version 2.5.1-L0 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:436) [2021-03-06 06:46:38,804] INFO AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2021-03-06 06:46:38,806] INFO KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2021-03-06 06:46:38,807] INFO KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2021-03-06 06:46:38,808] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 (io.confluent.connect.avro.AvroDataConfig:347) [2021-03-06 06:46:38,808] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task coyote_test_console_source-1615013196744-0 using the worker config (org.apache.kafka.connect.runtime.Worker:449) [2021-03-06 06:46:38,809] INFO AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2021-03-06 06:46:38,810] INFO KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2021-03-06 06:46:38,810] INFO KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [http://127.0.0.1:8081] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = use.latest.version = false schema.registry.ssl.enabled.protocols = [TLSv1.2] schema.registry.ssl.protocol = TLSv1.2 schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2021-03-06 06:46:38,813] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 (io.confluent.connect.avro.AvroDataConfig:347) [2021-03-06 06:46:38,814] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task coyote_test_console_source-1615013196744-0 using the worker config (org.apache.kafka.connect.runtime.Worker:455) [2021-03-06 06:46:38,814] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task coyote_test_console_source-1615013196744-0 using the worker config (org.apache.kafka.connect.runtime.Worker:462) [2021-03-06 06:46:38,815] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:516) [2021-03-06 06:46:38,817] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [PLAINTEXT://127.0.0.1:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = connector-producer-coyote_test_console_source-1615013196744-0 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 metadata.max.idle.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 security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] 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 = TLSv1.2 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:347) [2021-03-06 06:46:38,825] INFO Kafka version: 2.5.1-L0 (org.apache.kafka.common.utils.AppInfoParser:117) [2021-03-06 06:46:38,826] INFO Kafka commitId: 0efa8fb0f4c73d92 (org.apache.kafka.common.utils.AppInfoParser:118) [2021-03-06 06:46:38,827] INFO Kafka startTimeMs: 1615013198825 (org.apache.kafka.common.utils.AppInfoParser:119) [2021-03-06 06:46:38,831] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171) [2021-03-06 06:46:38,833] INFO WorkerSourceTask{id=coyote_test_console_source-1615013196744-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:216) [2021-03-06 06:46:38,834] INFO [Producer clientId=connector-producer-coyote_test_console_source-1615013196744-0] Cluster ID: HfUmm1LuTOSlFvzO39QCXQ (org.apache.kafka.clients.Metadata:277) [2021-03-06 06:46:39,230] WARN [Producer clientId=connector-producer-coyote_test_console_source-1615013196744-0] Error while fetching metadata with correlation id 3 : {coyote_cd-1615013196744=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:1077) [2021-03-06 06:46:53,281] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:46:53,282] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:46:53,300] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 19 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:47:04,956] INFO Successfully processed removal of connector 'coyote_test_console_source-1615013196744' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:559) [2021-03-06 06:47:04,958] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Connector coyote_test_console_source-1615013196744 config removed (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1429) [2021-03-06 06:47:05,459] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Handling connector-only config update by stopping connector coyote_test_console_source-1615013196744 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:547) [2021-03-06 06:47:05,460] INFO Stopping connector coyote_test_console_source-1615013196744 (org.apache.kafka.connect.runtime.Worker:360) [2021-03-06 06:47:05,462] INFO Stopped connector coyote_test_console_source-1615013196744 (org.apache.kafka.connect.runtime.Worker:376) [2021-03-06 06:47:05,462] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225) [2021-03-06 06:47:05,463] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) [2021-03-06 06:47:05,472] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 6 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503) [2021-03-06 06:47:05,475] INFO Stopping connector coyote_test_console_source-1615013196744 (org.apache.kafka.connect.runtime.Worker:360) [2021-03-06 06:47:05,475] INFO Stopping task coyote_test_console_source-1615013196744-0 (org.apache.kafka.connect.runtime.Worker:706) [2021-03-06 06:47:05,475] WARN Ignoring stop request for unowned connector coyote_test_console_source-1615013196744 (org.apache.kafka.connect.runtime.Worker:364) [2021-03-06 06:47:05,476] INFO WorkerSourceTask{id=coyote_test_console_source-1615013196744-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:47:05,476] INFO WorkerSourceTask{id=coyote_test_console_source-1615013196744-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:47:05,482] INFO WorkerSourceTask{id=coyote_test_console_source-1615013196744-0} Finished commitOffsets successfully in 6 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:47:05,482] INFO [Producer clientId=connector-producer-coyote_test_console_source-1615013196744-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1182) [2021-03-06 06:47:05,489] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1677) [2021-03-06 06:47:05,496] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished flushing status backing store in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1696) [2021-03-06 06:47:05,496] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Joined group at generation 6 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-643e33fb-8a83-4c82-a93e-a455d1a4d977', leaderUrl='http://172.17.0.2:8083/', offset=9, connectorIds=[logs-broker], taskIds=[logs-broker-0], revokedConnectorIds=[coyote_test_console_source-1615013196744], revokedTaskIds=[coyote_test_console_source-1615013196744-0], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1600) [2021-03-06 06:47:05,497] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connectors and tasks using config offset 9 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1143) [2021-03-06 06:47:05,497] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171) [2021-03-06 06:47:05,497] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225) [2021-03-06 06:47:05,498] INFO [Worker clientId=connect-1, groupId=connect-fast-data] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552) [2021-03-06 06:47:05,504] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Successfully joined group with generation 7 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503) [2021-03-06 06:47:05,504] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Joined group at generation 7 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-643e33fb-8a83-4c82-a93e-a455d1a4d977', leaderUrl='http://172.17.0.2:8083/', offset=9, connectorIds=[logs-broker], taskIds=[logs-broker-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1600) [2021-03-06 06:47:05,505] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Starting connectors and tasks using config offset 9 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1143) [2021-03-06 06:47:05,505] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171) [2021-03-06 06:47:53,301] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:47:53,303] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:47:53,307] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 4 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:48:53,308] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:48:53,309] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:48:53,316] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 7 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:49:53,317] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:49:53,318] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:49:53,323] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 5 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:50:53,324] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:50:53,325] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:50:53,328] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:51:53,329] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:51:53,330] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:51:53,336] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 6 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:52:53,337] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:52:53,338] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:53:53,339] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:53:53,340] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:54:53,341] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:54:53,342] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:54:53,350] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 8 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 06:55:53,350] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:55:53,351] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:56:53,351] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:56:53,352] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:57:53,353] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:57:53,354] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:58:53,355] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:58:53,356] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 06:59:53,357] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 06:59:53,358] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:00:53,360] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:00:53,365] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:01:53,365] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:01:53,366] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:02:53,367] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:02:53,368] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:03:53,369] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:03:53,370] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:04:53,371] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:04:53,372] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:04:53,379] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 8 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 07:05:53,380] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:05:53,381] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:06:53,382] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:06:53,382] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:07:53,383] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:07:53,385] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:08:53,386] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:08:53,386] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:09:53,387] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:09:53,388] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:10:53,388] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:10:53,389] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:11:53,390] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:11:53,391] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:12:53,392] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:12:53,392] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:13:53,393] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:13:53,394] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:14:53,394] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:14:53,395] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:14:53,402] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 7 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 07:15:53,403] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:15:53,404] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:16:53,405] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:16:53,406] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:17:53,406] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:17:53,407] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:18:53,407] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:18:53,408] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:19:53,409] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:19:53,409] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:20:53,410] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:20:53,411] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:21:53,412] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:21:53,414] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:22:53,414] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:22:53,415] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:23:53,416] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:23:53,416] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:24:53,417] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:24:53,417] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:24:53,424] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 7 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 07:25:53,425] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:25:53,427] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:26:53,428] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:26:53,430] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:27:53,431] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:27:53,432] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:28:53,433] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:28:53,434] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:29:53,435] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:29:53,436] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:30:53,437] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:30:53,437] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:31:53,438] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:31:53,438] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:32:53,439] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:32:53,441] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:33:53,442] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:33:53,442] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:34:53,443] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:34:53,445] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:34:53,452] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 6 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 07:35:53,452] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:35:53,453] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:36:53,453] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:36:53,454] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:37:53,455] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:37:53,456] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:38:53,457] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:38:53,459] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:39:53,459] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:39:53,460] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:40:53,461] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:40:53,461] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:41:53,462] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:41:53,463] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:42:53,464] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:42:53,465] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:43:53,466] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:43:53,466] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:44:53,467] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:44:53,468] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:44:53,474] INFO WorkerSourceTask{id=logs-broker-0} Finished commitOffsets successfully in 6 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:525) [2021-03-06 07:45:45,083] INFO [Worker clientId=connect-1, groupId=connect-fast-data] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1486) [2021-03-06 07:45:53,475] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:45:53,475] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443) [2021-03-06 07:46:53,476] INFO WorkerSourceTask{id=logs-broker-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:426) [2021-03-06 07:46:53,477] INFO WorkerSourceTask{id=logs-broker-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:443)