kafka-connect-ftp
kafka-connect-ftp copied to clipboard
Published
20 hours ago •
Eneco
Eneco
kafka-connect-ftp gives "inStream parameter is null" error
Here is the result what i am getting when doing kafka-connect-ftp: I cant able to find any parameter like instream in your example:
./connect-standalone ../etc/kafka/connect-standalone.properties ../etc/kafka/connect-file-source-sftp.properties
[2019-07-24 19:43:39,344] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:69)
[2019-07-24 19:43:39,370] INFO WorkerInfo values:
jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/var/log/kafka, -Dlog4j.configuration=file:./../etc/kafka/connect-log4j.properties
jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 11.0.2, 11.0.2+9-LTS
jvm.classpath = /opt/confluent_5_3_0/share/java/confluent-security/connect/confluent-connect-secret-registry-plugin-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jaxb-api-2.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-container-servlet-core-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-continuation-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/failureaccess-1.0.1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-jaxrs-json-provider-2.9.9.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax-websocket-client-impl-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-server-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.el-2.2.4.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/hk2-utils-2.5.0-b42.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/asm-commons-7.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/error_prone_annotations-2.2.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/protobuf-java-util-3.4.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/websocket-common-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-core-asl-1.9.13.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/bcpkix-jdk15on-1.60.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/commons-compress-1.8.1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-server-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-container-servlet-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/activation-1.1.1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/checker-qual-2.5.2.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-plus-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.el-api-2.2.4.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/kafka-schema-registry-client-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-servlets-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-jaas-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-webapp-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/hk2-locator-2.5.0-b42.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/avro-1.8.1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/websocket-api-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/websocket-client-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/confluent-security-plugins-common-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-datatype-jdk8-2.9.9.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/common-config-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/protobuf-java-3.4.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/asm-analysis-7.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-jndi-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.websocket-api-1.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/common-utils-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-annotations-2.9.9.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-bean-validation-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jose4j-0.6.4.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.ws.rs-api-2.1.1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jline-0.9.94.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/authorizer-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/validation-api-1.1.0.Final.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax-websocket-server-impl-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jboss-logging-3.1.3.GA.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-hk2-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/common-metrics-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/bcpg-jdk15on-1.61.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/paranamer-2.7.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/websocket-servlet-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/spotbugs-annotations-3.1.8.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/hibernate-validator-5.1.3.Final.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-xml-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/kafka-secret-registry-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.annotation-api-1.3.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/animal-sniffer-annotations-1.17.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-servlet-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/zookeeper-3.4.14.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/xz-1.5.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-mapper-asl-1.9.13.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-media-jaxb-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-module-jaxb-annotations-2.9.9.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/asm-tree-7.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/confluent-licensing-new-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jsr305-3.0.2.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-core-2.9.9.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-jaxrs-base-2.9.9.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/audience-annotations-0.5.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-util-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/hk2-api-2.5.0-b42.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.servlet-api-3.1.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-common-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/metrics-core-2.2.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/confluent-connect-security-plugin-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/kafka-secret-registry-client-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-io-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jersey-client-2.27.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jackson-databind-2.9.9.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.inject-1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/guava-27.1-jre.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javassist-3.22.0-CR2.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-annotations-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/classmate-1.0.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/zkclient-0.10.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/asm-7.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.inject-2.5.0-b42.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/confluent-serializers-new-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/netty-3.10.6.Final.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/j2objc-annotations-1.1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/rest-authorizer-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-security-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/kafka-client-plugins-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/rest-utils-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/websocket-server-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/javax.websocket-client-api-1.0.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/bcprov-jdk15on-1.60.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-jmx-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/osgi-resource-locator-1.0.1.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/gson-2.8.5.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/aopalliance-repackaged-2.5.0-b42.jar:/opt/confluent_5_3_0/share/java/confluent-security/connect/jetty-http-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/jaxb-api-2.3.0.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-continuation-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-jaxrs-json-provider-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/spotbugs-annotations-3.1.9.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-server-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/bcprov-jdk15on-1.61.jar:/opt/confluent_5_3_0/share/java/kafka/connect-transforms-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-streams-scala_2.12-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/protobuf-java-util-3.4.0.jar:/opt/confluent_5_3_0/share/java/kafka/snappy-java-1.1.7.3.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-core-asl-1.9.13.jar:/opt/confluent_5_3_0/share/java/kafka/connect-file-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:/opt/confluent_5_3_0/share/java/kafka/jakarta.annotation-api-1.3.4.jar:/opt/confluent_5_3_0/share/java/kafka/commons-compress-1.8.1.jar:/opt/confluent_5_3_0/share/java/kafka/connect-api-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/zstd-jni-1.4.0-1.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-streams-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/activation-1.1.1.jar:/opt/confluent_5_3_0/share/java/kafka/support-metrics-common-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/rbac-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/commons-logging-1.2.jar:/opt/confluent_5_3_0/share/java/kafka/commons-lang3-3.8.1.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-clients-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-servlets-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/scala-logging_2.12-3.9.0.jar:/opt/confluent_5_3_0/share/java/kafka/httpcore-4.4.11.jar:/opt/confluent_5_3_0/share/java/kafka/auth-providers-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/validation-api-2.0.1.Final.jar:/opt/confluent_5_3_0/share/java/kafka/scala-java8-compat_2.12-0.9.0.jar:/opt/confluent_5_3_0/share/java/kafka/avro-1.8.1.jar:/opt/confluent_5_3_0/share/java/kafka/jopt-simple-5.0.4.jar:/opt/confluent_5_3_0/share/java/kafka/connect-json-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/slf4j-log4j12-1.7.26.jar:/opt/confluent_5_3_0/share/java/kafka/httpclient-4.5.7.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-datatype-jdk8-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/connect-basic-auth-extension-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/protobuf-java-3.4.0.jar:/opt/confluent_5_3_0/share/java/kafka/scala-library-2.12.8.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-annotations-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/jose4j-0.6.4.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-client-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/javax.ws.rs-api-2.1.1.jar:/opt/confluent_5_3_0/share/java/kafka/jline-0.9.94.jar:/opt/confluent_5_3_0/share/java/kafka/authorizer-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-streams-examples-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/kafka.jar:/opt/confluent_5_3_0/share/java/kafka/paranamer-2.7.jar:/opt/confluent_5_3_0/share/java/kafka/jersey-common-2.28.jar:/opt/confluent_5_3_0/share/java/kafka/bcpkix-jdk15on-1.61.jar:/opt/confluent_5_3_0/share/java/kafka/kafka_2.12-5.3.0-ce-test.jar:/opt/confluent_5_3_0/share/java/kafka/lz4-java-1.6.0.jar:/opt/confluent_5_3_0/share/java/kafka/jersey-container-servlet-2.28.jar:/opt/confluent_5_3_0/share/java/kafka/aopalliance-repackaged-2.5.0.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-servlet-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/rocksdbjni-5.18.3.jar:/opt/confluent_5_3_0/share/java/kafka/joda-time-2.8.1.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-log4j-appender-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/hk2-utils-2.5.0.jar:/opt/confluent_5_3_0/share/java/kafka/zookeeper-3.4.14.jar:/opt/confluent_5_3_0/share/java/kafka/xz-1.5.jar:/opt/confluent_5_3_0/share/java/kafka/kafka_2.12-5.3.0-ce-javadoc.jar:/opt/confluent_5_3_0/share/java/kafka/httpmime-4.5.7.jar:/opt/confluent_5_3_0/share/java/kafka/slf4j-api-1.7.26.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-mapper-asl-1.9.13.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-module-jaxb-annotations-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/httpcore-4.4.9.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-streams-test-utils-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/commons-codec-1.11.jar:/opt/confluent_5_3_0/share/java/kafka/argparse4j-0.7.0.jar:/opt/confluent_5_3_0/share/java/kafka/jersey-server-2.28.jar:/opt/confluent_5_3_0/share/java/kafka/jsr305-3.0.2.jar:/opt/confluent_5_3_0/share/java/kafka/plexus-utils-3.2.0.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-core-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/kafka_2.12-5.3.0-ce-scaladoc.jar:/opt/confluent_5_3_0/share/java/kafka/confluent-metrics-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-jaxrs-base-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/ion-java-1.0.2.jar:/opt/confluent_5_3_0/share/java/kafka/audience-annotations-0.5.0.jar:/opt/confluent_5_3_0/share/java/kafka/jmespath-java-1.11.475.jar:/opt/confluent_5_3_0/share/java/kafka/jersey-container-servlet-core-2.28.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-util-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/javax.servlet-api-3.1.0.jar:/opt/confluent_5_3_0/share/java/kafka/hk2-api-2.5.0.jar:/opt/confluent_5_3_0/share/java/kafka/reflections-0.9.11.jar:/opt/confluent_5_3_0/share/java/kafka/aws-java-sdk-kms-1.11.475.jar:/opt/confluent_5_3_0/share/java/kafka/connect-runtime-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/metrics-core-2.2.0.jar:/opt/confluent_5_3_0/share/java/kafka/guava-20.0.jar:/opt/confluent_5_3_0/share/java/kafka/httpclient-4.5.5.jar:/opt/confluent_5_3_0/share/java/kafka/maven-artifact-3.6.1.jar:/opt/confluent_5_3_0/share/java/kafka/jbcrypt-0.4.jar:/opt/confluent_5_3_0/share/java/kafka/commons-codec-1.10.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-io-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-databind-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/zkclient-0.11.jar:/opt/confluent_5_3_0/share/java/kafka/scala-reflect-2.12.8.jar:/opt/confluent_5_3_0/share/java/kafka/support-metrics-fullcollector-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/javassist-3.22.0-CR2.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-module-paranamer-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/paranamer-2.8.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-dataformat-csv-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/aws-java-sdk-s3-1.11.475.jar:/opt/confluent_5_3_0/share/java/kafka/flatbuffers-java-1.9.0.jar:/opt/confluent_5_3_0/share/java/kafka/broker-plugins-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/jersey-hk2-2.28.jar:/opt/confluent_5_3_0/share/java/kafka/hk2-locator-2.5.0.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-tools-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-module-scala_2.12-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka/rest-authorizer-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-security-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/kafka/kafka-client-plugins-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/aws-java-sdk-core-1.11.475.jar:/opt/confluent_5_3_0/share/java/kafka/jersey-client-2.28.jar:/opt/confluent_5_3_0/share/java/kafka/support-metrics-client-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/log4j-1.2.17.jar:/opt/confluent_5_3_0/share/java/kafka/kafka_2.12-5.3.0-ce.jar:/opt/confluent_5_3_0/share/java/kafka/osgi-resource-locator-1.0.1.jar:/opt/confluent_5_3_0/share/java/kafka/jakarta.inject-2.5.0.jar:/opt/confluent_5_3_0/share/java/kafka/jersey-media-jaxb-2.28.jar:/opt/confluent_5_3_0/share/java/kafka/gson-2.8.5.jar:/opt/confluent_5_3_0/share/java/kafka/jackson-dataformat-cbor-2.6.7.jar:/opt/confluent_5_3_0/share/java/kafka/jetty-http-9.4.18.v20190429.jar:/opt/confluent_5_3_0/share/java/confluent-common/common-config-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-common/common-utils-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-common/jline-0.9.94.jar:/opt/confluent_5_3_0/share/java/confluent-common/common-metrics-5.3.0.jar:/opt/confluent_5_3_0/share/java/confluent-common/spotbugs-annotations-3.1.8.jar:/opt/confluent_5_3_0/share/java/confluent-common/zookeeper-3.4.14.jar:/opt/confluent_5_3_0/share/java/confluent-common/slf4j-api-1.7.26.jar:/opt/confluent_5_3_0/share/java/confluent-common/jsr305-3.0.2.jar:/opt/confluent_5_3_0/share/java/confluent-common/audience-annotations-0.5.0.jar:/opt/confluent_5_3_0/share/java/confluent-common/zkclient-0.10.jar:/opt/confluent_5_3_0/share/java/confluent-common/netty-3.10.6.Final.jar:/opt/confluent_5_3_0/share/java/confluent-common/build-tools-5.3.0.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/snappy-java-1.1.1.3.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/commons-compress-1.8.1.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/kafka-schema-registry-client-5.3.0.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/avro-1.8.1.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/jackson-annotations-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/paranamer-2.7.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/xz-1.5.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/kafka-avro-serializer-5.3.0.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/jackson-core-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/jackson-databind-2.9.9.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.3.0.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/kafka-json-serializer-5.3.0.jar:/opt/confluent_5_3_0/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.3.0.jar:/opt/confluent_5_3_0/share/java/monitoring-interceptors/monitoring-interceptors-5.3.0.jar:./../ce-broker-plugins/build/libs/:./../ce-broker-plugins/build/dependant-libs/:./../ce-auth-providers/build/libs/:./../ce-auth-providers/build/dependant-libs/:./../share/java/kafka/jaxb-api-2.3.0.jar:./../share/java/kafka/jetty-continuation-9.4.18.v20190429.jar:./../share/java/kafka/jackson-jaxrs-json-provider-2.9.9.jar:./../share/java/kafka/spotbugs-annotations-3.1.9.jar:./../share/java/kafka/jetty-server-9.4.18.v20190429.jar:./../share/java/kafka/bcprov-jdk15on-1.61.jar:./../share/java/kafka/connect-transforms-5.3.0-ce.jar:./../share/java/kafka/kafka-streams-scala_2.12-5.3.0-ce.jar:./../share/java/kafka/protobuf-java-util-3.4.0.jar:./../share/java/kafka/snappy-java-1.1.7.3.jar:./../share/java/kafka/jackson-core-asl-1.9.13.jar:./../share/java/kafka/connect-file-5.3.0-ce.jar:./../share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:./../share/java/kafka/jakarta.annotation-api-1.3.4.jar:./../share/java/kafka/commons-compress-1.8.1.jar:./../share/java/kafka/connect-api-5.3.0-ce.jar:./../share/java/kafka/zstd-jni-1.4.0-1.jar:./../share/java/kafka/kafka-streams-5.3.0-ce.jar:./../share/java/kafka/activation-1.1.1.jar:./../share/java/kafka/support-metrics-common-5.3.0-ce.jar:./../share/java/kafka/rbac-5.3.0-ce.jar:./../share/java/kafka/commons-logging-1.2.jar:./../share/java/kafka/commons-lang3-3.8.1.jar:./../share/java/kafka/kafka-clients-5.3.0-ce.jar:./../share/java/kafka/jetty-servlets-9.4.18.v20190429.jar:./../share/java/kafka/scala-logging_2.12-3.9.0.jar:./../share/java/kafka/httpcore-4.4.11.jar:./../share/java/kafka/auth-providers-5.3.0-ce.jar:./../share/java/kafka/validation-api-2.0.1.Final.jar:./../share/java/kafka/scala-java8-compat_2.12-0.9.0.jar:./../share/java/kafka/avro-1.8.1.jar:./../share/java/kafka/jopt-simple-5.0.4.jar:./../share/java/kafka/connect-json-5.3.0-ce.jar:./../share/java/kafka/slf4j-log4j12-1.7.26.jar:./../share/java/kafka/httpclient-4.5.7.jar:./../share/java/kafka/jackson-datatype-jdk8-2.9.9.jar:./../share/java/kafka/connect-basic-auth-extension-5.3.0-ce.jar:./../share/java/kafka/protobuf-java-3.4.0.jar:./../share/java/kafka/scala-library-2.12.8.jar:./../share/java/kafka/jackson-annotations-2.9.9.jar:./../share/java/kafka/jose4j-0.6.4.jar:./../share/java/kafka/jetty-client-9.4.18.v20190429.jar:./../share/java/kafka/javax.ws.rs-api-2.1.1.jar:./../share/java/kafka/jline-0.9.94.jar:./../share/java/kafka/authorizer-5.3.0-ce.jar:./../share/java/kafka/kafka-streams-examples-5.3.0-ce.jar:./../share/java/kafka/kafka.jar:./../share/java/kafka/paranamer-2.7.jar:./../share/java/kafka/jersey-common-2.28.jar:./../share/java/kafka/bcpkix-jdk15on-1.61.jar:./../share/java/kafka/kafka_2.12-5.3.0-ce-test.jar:./../share/java/kafka/lz4-java-1.6.0.jar:./../share/java/kafka/jersey-container-servlet-2.28.jar:./../share/java/kafka/aopalliance-repackaged-2.5.0.jar:./../share/java/kafka/jetty-servlet-9.4.18.v20190429.jar:./../share/java/kafka/rocksdbjni-5.18.3.jar:./../share/java/kafka/joda-time-2.8.1.jar:./../share/java/kafka/kafka-log4j-appender-5.3.0-ce.jar:./../share/java/kafka/hk2-utils-2.5.0.jar:./../share/java/kafka/zookeeper-3.4.14.jar:./../share/java/kafka/xz-1.5.jar:./../share/java/kafka/kafka_2.12-5.3.0-ce-javadoc.jar:./../share/java/kafka/httpmime-4.5.7.jar:./../share/java/kafka/slf4j-api-1.7.26.jar:./../share/java/kafka/jackson-mapper-asl-1.9.13.jar:./../share/java/kafka/jackson-module-jaxb-annotations-2.9.9.jar:./../share/java/kafka/httpcore-4.4.9.jar:./../share/java/kafka/kafka-streams-test-utils-5.3.0-ce.jar:./../share/java/kafka/commons-codec-1.11.jar:./../share/java/kafka/argparse4j-0.7.0.jar:./../share/java/kafka/jersey-server-2.28.jar:./../share/java/kafka/jsr305-3.0.2.jar:./../share/java/kafka/plexus-utils-3.2.0.jar:./../share/java/kafka/jackson-core-2.9.9.jar:./../share/java/kafka/kafka_2.12-5.3.0-ce-scaladoc.jar:./../share/java/kafka/confluent-metrics-5.3.0-ce.jar:./../share/java/kafka/jackson-jaxrs-base-2.9.9.jar:./../share/java/kafka/ion-java-1.0.2.jar:./../share/java/kafka/audience-annotations-0.5.0.jar:./../share/java/kafka/jmespath-java-1.11.475.jar:./../share/java/kafka/jersey-container-servlet-core-2.28.jar:./../share/java/kafka/jetty-util-9.4.18.v20190429.jar:./../share/java/kafka/javax.servlet-api-3.1.0.jar:./../share/java/kafka/hk2-api-2.5.0.jar:./../share/java/kafka/reflections-0.9.11.jar:./../share/java/kafka/aws-java-sdk-kms-1.11.475.jar:./../share/java/kafka/connect-runtime-5.3.0-ce.jar:./../share/java/kafka/metrics-core-2.2.0.jar:./../share/java/kafka/guava-20.0.jar:./../share/java/kafka/httpclient-4.5.5.jar:./../share/java/kafka/maven-artifact-3.6.1.jar:./../share/java/kafka/jbcrypt-0.4.jar:./../share/java/kafka/commons-codec-1.10.jar:./../share/java/kafka/jetty-io-9.4.18.v20190429.jar:./../share/java/kafka/jackson-databind-2.9.9.jar:./../share/java/kafka/zkclient-0.11.jar:./../share/java/kafka/scala-reflect-2.12.8.jar:./../share/java/kafka/support-metrics-fullcollector-5.3.0-ce.jar:./../share/java/kafka/javassist-3.22.0-CR2.jar:./../share/java/kafka/jackson-module-paranamer-2.9.9.jar:./../share/java/kafka/paranamer-2.8.jar:./../share/java/kafka/jackson-dataformat-csv-2.9.9.jar:./../share/java/kafka/aws-java-sdk-s3-1.11.475.jar:./../share/java/kafka/flatbuffers-java-1.9.0.jar:./../share/java/kafka/broker-plugins-5.3.0-ce.jar:./../share/java/kafka/jersey-hk2-2.28.jar:./../share/java/kafka/hk2-locator-2.5.0.jar:./../share/java/kafka/kafka-tools-5.3.0-ce.jar:./../share/java/kafka/jackson-module-scala_2.12-2.9.9.jar:./../share/java/kafka/rest-authorizer-5.3.0-ce.jar:./../share/java/kafka/jetty-security-9.4.18.v20190429.jar:./../share/java/kafka/kafka-client-plugins-5.3.0-ce.jar:./../share/java/kafka/aws-java-sdk-core-1.11.475.jar:./../share/java/kafka/jersey-client-2.28.jar:./../share/java/kafka/support-metrics-client-5.3.0-ce.jar:./../share/java/kafka/log4j-1.2.17.jar:./../share/java/kafka/kafka_2.12-5.3.0-ce.jar:./../share/java/kafka/osgi-resource-locator-1.0.1.jar:./../share/java/kafka/jakarta.inject-2.5.0.jar:./../share/java/kafka/jersey-media-jaxb-2.28.jar:./../share/java/kafka/gson-2.8.5.jar:./../share/java/kafka/jackson-dataformat-cbor-2.6.7.jar:./../share/java/kafka/jetty-http-9.4.18.v20190429.jar:./../share/java/confluent-metadata-service/javax.el-2.2.4.jar:./../share/java/confluent-metadata-service/snappy-java-1.1.7.3.jar:./../share/java/confluent-metadata-service/jackson-core-asl-1.9.13.jar:./../share/java/confluent-metadata-service/bcpkix-jdk15on-1.60.jar:./../share/java/confluent-metadata-service/commons-compress-1.8.1.jar:./../share/java/confluent-metadata-service/jersey-server-2.27.jar:./../share/java/confluent-metadata-service/zstd-jni-1.4.0-1.jar:./../share/java/confluent-metadata-service/javax.el-api-2.2.4.jar:./../share/java/confluent-metadata-service/rbac-5.3.0-ce.jar:./../share/java/confluent-metadata-service/commons-logging-1.2.jar:./../share/java/confluent-metadata-service/kafka-schema-registry-client-5.3.0.jar:./../share/java/confluent-metadata-service/commons-lang3-3.8.1.jar:./../share/java/confluent-metadata-service/kafka-clients-5.3.0-ce.jar:./../share/java/confluent-metadata-service/scala-logging_2.12-3.9.0.jar:./../share/java/confluent-metadata-service/auth-providers-5.3.0-ce.jar:./../share/java/confluent-metadata-service/scala-java8-compat_2.12-0.9.0.jar:./../share/java/confluent-metadata-service/avro-1.8.1.jar:./../share/java/confluent-metadata-service/jopt-simple-5.0.4.jar:./../share/java/confluent-metadata-service/jul-to-slf4j-1.7.26.jar:./../share/java/confluent-metadata-service/confluent-security-plugins-common-5.3.0.jar:./../share/java/confluent-metadata-service/jackson-datatype-jdk8-2.9.9.jar:./../share/java/confluent-metadata-service/common-utils-5.3.0.jar:./../share/java/confluent-metadata-service/scala-library-2.12.8.jar:./../share/java/confluent-metadata-service/jersey-bean-validation-2.27.jar:./../share/java/confluent-metadata-service/jose4j-0.6.4.jar:./../share/java/confluent-metadata-service/jetty-client-9.4.18.v20190429.jar:./../share/java/confluent-metadata-service/javax.ws.rs-api-2.1.1.jar:./../share/java/confluent-metadata-service/jline-0.9.94.jar:./../share/java/confluent-metadata-service/authorizer-5.3.0-ce.jar:./../share/java/confluent-metadata-service/jetty-proxy-9.4.18.v20190429.jar:./../share/java/confluent-metadata-service/validation-api-1.1.0.Final.jar:./../share/java/confluent-metadata-service/jboss-logging-3.1.3.GA.jar:./../share/java/confluent-metadata-service/spotbugs-annotations-3.1.8.jar:./../share/java/confluent-metadata-service/lz4-java-1.6.0.jar:./../share/java/confluent-metadata-service/hibernate-validator-5.1.3.Final.jar:./../share/java/confluent-metadata-service/joda-time-2.8.1.jar:./../share/java/confluent-metadata-service/zookeeper-3.4.14.jar:./../share/java/confluent-metadata-service/xz-1.5.jar:./../share/java/confluent-metadata-service/javax.annotation-api-1.2.jar:./../share/java/confluent-metadata-service/jackson-mapper-asl-1.9.13.jar:./../share/java/confluent-metadata-service/jersey-media-jaxb-2.27.jar:./../share/java/confluent-metadata-service/jsr305-3.0.2.jar:./../share/java/confluent-metadata-service/ion-java-1.0.2.jar:./../share/java/confluent-metadata-service/audience-annotations-0.5.0.jar:./../share/java/confluent-metadata-service/jmespath-java-1.11.475.jar:./../share/java/confluent-metadata-service/jetty-util-9.4.18.v20190429.jar:./../share/java/confluent-metadata-service/jersey-common-2.27.jar:./../share/java/confluent-metadata-service/aws-java-sdk-kms-1.11.475.jar:./../share/java/confluent-metadata-service/metrics-core-2.2.0.jar:./../share/java/confluent-metadata-service/guava-20.0.jar:./../share/java/confluent-metadata-service/commons-codec-1.9.jar:./../share/java/confluent-metadata-service/jbcrypt-0.4.jar:./../share/java/confluent-metadata-service/rbac-api-server-5.3.0.jar:./../share/java/confluent-metadata-service/jersey-client-2.27.jar:./../share/java/confluent-metadata-service/scala-reflect-2.12.8.jar:./../share/java/confluent-metadata-service/jackson-module-paranamer-2.9.9.jar:./../share/java/confluent-metadata-service/paranamer-2.8.jar:./../share/java/confluent-metadata-service/jackson-dataformat-csv-2.9.9.jar:./../share/java/confluent-metadata-service/aws-java-sdk-s3-1.11.475.jar:./../share/java/confluent-metadata-service/flatbuffers-java-1.9.0.jar:./../share/java/confluent-metadata-service/classmate-1.0.0.jar:./../share/java/confluent-metadata-service/fluent-hc-4.5.8.jar:./../share/java/confluent-metadata-service/zkclient-0.10.jar:./../share/java/confluent-metadata-service/httpcore-4.4.6.jar:./../share/java/confluent-metadata-service/httpclient-4.5.3.jar:./../share/java/confluent-metadata-service/javax.inject-2.5.0-b42.jar:./../share/java/confluent-metadata-service/netty-3.10.6.Final.jar:./../share/java/confluent-metadata-service/jackson-module-scala_2.12-2.9.9.jar:./../share/java/confluent-metadata-service/rest-authorizer-5.3.0-ce.jar:./../share/java/confluent-metadata-service/kafka-client-plugins-5.3.0-ce.jar:./../share/java/confluent-metadata-service/bcprov-jdk15on-1.60.jar:./../share/java/confluent-metadata-service/aws-java-sdk-core-1.11.475.jar:./../share/java/confluent-metadata-service/kafka_2.12-5.3.0-ce.jar:./../share/java/confluent-metadata-service/osgi-resource-locator-1.0.1.jar:./../share/java/confluent-metadata-service/gson-2.8.5.jar:./../share/java/confluent-metadata-service/jackson-dataformat-cbor-2.6.7.jar:./../share/java/rest-utils/jaxb-api-2.3.0.jar:./../share/java/rest-utils/jersey-container-servlet-core-2.27.jar:./../share/java/rest-utils/jetty-continuation-9.4.18.v20190429.jar:./../share/java/rest-utils/jackson-jaxrs-json-provider-2.9.9.jar:./../share/java/rest-utils/javax-websocket-client-impl-9.4.18.v20190429.jar:./../share/java/rest-utils/jetty-server-9.4.18.v20190429.jar:./../share/java/rest-utils/javax.el-2.2.4.jar:./../share/java/rest-utils/hk2-utils-2.5.0-b42.jar:./../share/java/rest-utils/asm-commons-7.0.jar:./../share/java/rest-utils/snappy-java-1.1.7.3.jar:./../share/java/rest-utils/websocket-common-9.4.18.v20190429.jar:./../share/java/rest-utils/jersey-server-2.27.jar:./../share/java/rest-utils/jersey-container-servlet-2.27.jar:./../share/java/rest-utils/zstd-jni-1.4.0-1.jar:./../share/java/rest-utils/activation-1.1.1.jar:./../share/java/rest-utils/jetty-plus-9.4.18.v20190429.jar:./../share/java/rest-utils/javax.el-api-2.2.4.jar:./../share/java/rest-utils/jetty-servlets-9.4.18.v20190429.jar:./../share/java/rest-utils/jetty-jaas-9.4.18.v20190429.jar:./../share/java/rest-utils/jetty-webapp-9.4.18.v20190429.jar:./../share/java/rest-utils/hk2-locator-2.5.0-b42.jar:./../share/java/rest-utils/websocket-api-9.4.18.v20190429.jar:./../share/java/rest-utils/websocket-client-9.4.18.v20190429.jar:./../share/java/rest-utils/asm-analysis-7.0.jar:./../share/java/rest-utils/jetty-jndi-9.4.18.v20190429.jar:./../share/java/rest-utils/javax.websocket-api-1.0.jar:./../share/java/rest-utils/jackson-annotations-2.9.9.jar:./../share/java/rest-utils/jersey-bean-validation-2.27.jar:./../share/java/rest-utils/jetty-client-9.4.18.v20190429.jar:./../share/java/rest-utils/validation-api-1.1.0.Final.jar:./../share/java/rest-utils/javax-websocket-server-impl-9.4.18.v20190429.jar:./../share/java/rest-utils/jboss-logging-3.1.3.GA.jar:./../share/java/rest-utils/jersey-hk2-2.27.jar:./../share/java/rest-utils/websocket-servlet-9.4.18.v20190429.jar:./../share/java/rest-utils/lz4-java-1.6.0.jar:./../share/java/rest-utils/hibernate-validator-5.1.3.Final.jar:./../share/java/rest-utils/jetty-xml-9.4.18.v20190429.jar:./../share/java/rest-utils/javax.annotation-api-1.3.jar:./../share/java/rest-utils/jetty-servlet-9.4.18.v20190429.jar:./../share/java/rest-utils/jersey-media-jaxb-2.27.jar:./../share/java/rest-utils/jackson-module-jaxb-annotations-2.9.9.jar:./../share/java/rest-utils/asm-tree-7.0.jar:./../share/java/rest-utils/kafka-clients-5.3.0-ccs.jar:./../share/java/rest-utils/jackson-core-2.9.9.jar:./../share/java/rest-utils/jackson-jaxrs-base-2.9.9.jar:./../share/java/rest-utils/jetty-util-9.4.18.v20190429.jar:./../share/java/rest-utils/hk2-api-2.5.0-b42.jar:./../share/java/rest-utils/javax.servlet-api-3.1.0.jar:./../share/java/rest-utils/jersey-common-2.27.jar:./../share/java/rest-utils/jetty-io-9.4.18.v20190429.jar:./../share/java/rest-utils/jersey-client-2.27.jar:./../share/java/rest-utils/jackson-databind-2.9.9.jar:./../share/java/rest-utils/javax.inject-1.jar:./../share/java/rest-utils/javassist-3.22.0-CR2.jar:./../share/java/rest-utils/jetty-annotations-9.4.18.v20190429.jar:./../share/java/rest-utils/classmate-1.0.0.jar:./../share/java/rest-utils/javax.ws.rs-api-2.1.jar:./../share/java/rest-utils/asm-7.0.jar:./../share/java/rest-utils/javax.inject-2.5.0-b42.jar:./../share/java/rest-utils/jetty-security-9.4.18.v20190429.jar:./../share/java/rest-utils/rest-utils-5.3.0.jar:./../share/java/rest-utils/websocket-server-9.4.18.v20190429.jar:./../share/java/rest-utils/javax.websocket-client-api-1.0.jar:./../share/java/rest-utils/jetty-jmx-9.4.18.v20190429.jar:./../share/java/rest-utils/osgi-resource-locator-1.0.1.jar:./../share/java/rest-utils/aopalliance-repackaged-2.5.0-b42.jar:./../share/java/rest-utils/jetty-http-9.4.18.v20190429.jar:./../share/java/confluent-common/common-config-5.3.0.jar:./../share/java/confluent-common/common-utils-5.3.0.jar:./../share/java/confluent-common/jline-0.9.94.jar:./../share/java/confluent-common/common-metrics-5.3.0.jar:./../share/java/confluent-common/spotbugs-annotations-3.1.8.jar:./../share/java/confluent-common/zookeeper-3.4.14.jar:./../share/java/confluent-common/slf4j-api-1.7.26.jar:./../share/java/confluent-common/jsr305-3.0.2.jar:./../share/java/confluent-common/audience-annotations-0.5.0.jar:./../share/java/confluent-common/zkclient-0.10.jar:./../share/java/confluent-common/netty-3.10.6.Final.jar:./../share/java/confluent-common/build-tools-5.3.0.jar:./../support-metrics-client/build/dependant-libs-2.12.8/:./../support-metrics-client/build/libs/:/usr/share/java/support-metrics-client/:./../support-metrics-fullcollector/build/dependant-libs-2.12.8/:./../support-metrics-fullcollector/build/libs/:/usr/share/java/support-metrics-fullcollector/
os.spec = Linux, amd64, 4.15.0-54-generic
os.vcpus = 4
(org.apache.kafka.connect.runtime.WorkerInfo:71)
[2019-07-24 19:43:39,377] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:78)
[2019-07-24 19:43:39,410] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-activemq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:40,634] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-activemq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:40,635] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,635] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,636] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,636] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,636] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,637] INFO Added plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,637] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,637] INFO Added plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,637] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,637] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,638] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,639] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,639] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,640] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,640] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,640] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,640] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,640] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,640] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,641] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,641] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,641] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,641] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,641] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,641] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,642] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,642] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,642] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,642] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,642] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,642] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,642] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,643] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,643] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,643] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,643] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,643] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,643] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,644] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:40,646] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-sftp-connect (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:41,334] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-sftp-connect/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:41,335] INFO Added plugin 'com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:41,335] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:41,336] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-replicator (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:42,435] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-replicator/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:42,435] INFO Added plugin 'io.confluent.connect.replicator.ReplicatorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:42,436] INFO Added plugin 'io.confluent.connect.replicator.util.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:42,436] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:42,437] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/schema-registry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:43,108] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/schema-registry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:43,109] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:44,038] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:44,038] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:44,038] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:44,038] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:44,039] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-ibmmq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:44,316] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-ibmmq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:44,317] INFO Added plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:44,317] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:46,234] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:46,234] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:46,234] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:46,234] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:46,235] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:46,235] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-jms (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:46,376] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-jms/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:46,377] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:46,483] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:46,483] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:46,484] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:46,495] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/confluent-security (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:49,517] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/confluent-security/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:49,518] INFO Added plugin 'io.confluent.kafka.secretregistry.client.config.provider.SecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:49,518] INFO Added plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:49,519] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/confluent-rebalancer (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:50,181] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/confluent-rebalancer/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:50,181] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/confluent-metadata-service (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:50,853] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/confluent-metadata-service/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:50,854] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-hdfs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:53,078] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-hdfs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:53,079] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:53,079] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:53,114] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-rest (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:53,663] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-rest/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:53,663] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/rest-utils (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:53,850] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/rest-utils/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:53,851] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/monitoring-interceptors (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:54,025] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/monitoring-interceptors/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:54,026] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/confluent-control-center (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:54,852] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/confluent-control-center/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:54,852] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/confluent-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:54,914] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/confluent-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:54,914] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/confluent-hub-client (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:55,054] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/confluent-hub-client/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:55,054] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/confluent-kafka-mqtt (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:55,552] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/confluent-kafka-mqtt/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:55,552] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-storage-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:56,389] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-storage-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:56,390] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/acl (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:58,060] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/acl/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:58,060] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/ksql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:58,384] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/ksql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:58,385] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:58,473] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:43:58,474] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-07-24 19:43:58,474] INFO Loading plugin from: /opt/confluent_5_3_0/share/java/kafka-serde-tools (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-07-24 19:43:58,552] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/confluent_5_3_0/share/java/kafka-serde-tools/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:44:01,638] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@368239c8 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-07-24 19:44:01,639] INFO Added aliases 'FtpSourceConnector' and 'FtpSource' to plugin 'com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,640] INFO Added aliases 'ActiveMQSourceConnector' and 'ActiveMQSource' to plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,640] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,640] INFO Added aliases 'HdfsSinkConnector' and 'HdfsSink' to plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,640] INFO Added aliases 'IbmMQSourceConnector' and 'IbmMQSource' to plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,641] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,641] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,641] INFO Added aliases 'JmsSourceConnector' and 'JmsSource' to plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,641] INFO Added aliases 'ReplicatorSourceConnector' and 'ReplicatorSource' to plugin 'io.confluent.connect.replicator.ReplicatorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,641] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,641] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,642] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,642] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,642] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,642] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,642] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,643] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,643] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,643] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,643] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,643] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,643] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,643] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,644] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,644] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,644] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,644] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,644] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,644] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,644] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,645] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,645] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-07-24 19:44:01,645] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,645] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-07-24 19:44:01,645] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-07-24 19:44:01,646] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-07-24 19:44:01,646] INFO Added alias 'ConnectSecurityExtension' to plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-07-24 19:44:01,646] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-07-24 19:44:01,646] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,646] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,646] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-07-24 19:44:01,666] INFO StandaloneConfig values:
access.control.allow.methods =
access.control.allow.origin =
bootstrap.servers = [192.168.1.195:9092]
client.dns.lookup = default
config.providers = []
connector.client.config.override.policy = None
header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
key.converter = class org.apache.kafka.connect.json.JsonConverter
listeners = null
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
offset.flush.interval.ms = 10000
offset.flush.timeout.ms = 5000
offset.storage.file.filename = /tmp/connect.offsets
plugin.path = [/opt/confluent_5_3_0/share/java]
rest.advertised.host.name = null
rest.advertised.listener = null
rest.advertised.port = null
rest.extension.classes = []
rest.host.name = null
rest.port = 8083
rest.servlet.initializor.classes = []
ssl.client.auth = none
task.shutdown.graceful.timeout.ms = 5000
value.converter = class org.apache.kafka.connect.json.JsonConverter
(org.apache.kafka.connect.runtime.standalone.StandaloneConfig:347)
[2019-07-24 19:44:01,668] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
[2019-07-24 19:44:01,677] INFO AdminClientConfig values:
bootstrap.servers = [192.168.1.195:9092]
client.dns.lookup = default
client.id =
connections.max.idle.ms = 300000
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 120000
retries = 5
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
send.buffer.bytes = 131072
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = https
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(org.apache.kafka.clients.admin.AdminClientConfig:347)
[2019-07-24 19:44:01,726] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-07-24 19:44:01,726] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-07-24 19:44:01,726] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-07-24 19:44:01,726] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-07-24 19:44:01,727] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-07-24 19:44:01,727] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-07-24 19:44:01,727] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-07-24 19:44:01,727] INFO Kafka version: 5.3.0-ce (org.apache.kafka.common.utils.AppInfoParser:117)
[2019-07-24 19:44:01,727] INFO Kafka commitId: a0f453a8a5e8c137 (org.apache.kafka.common.utils.AppInfoParser:118)
[2019-07-24 19:44:01,727] INFO Kafka startTimeMs: 1563977641727 (org.apache.kafka.common.utils.AppInfoParser:119)
[2019-07-24 19:44:01,941] INFO Kafka cluster ID: KektIB4tQ_OUkNw-_zXxrA (org.apache.kafka.connect.util.ConnectUtils:59)
[2019-07-24 19:44:01,960] INFO Logging initialized @23364ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
[2019-07-24 19:44:02,003] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:125)
[2019-07-24 19:44:02,004] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:169)
[2019-07-24 19:44:02,010] INFO jetty-9.4.18.v20190429; built: 2019-04-29T20:42:08.989Z; git: e1bc35120a6617ee3df052294e433f3a25ce7097; jvm 11.0.2+9-LTS (org.eclipse.jetty.server.Server:370)
[2019-07-24 19:44:02,037] INFO Started http_8083@5f6494c0{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:292)
[2019-07-24 19:44:02,037] INFO Started @23441ms (org.eclipse.jetty.server.Server:410)
[2019-07-24 19:44:02,063] INFO Advertised URI: http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:288)
[2019-07-24 19:44:02,063] INFO REST server listening at http://127.0.1.1:8083/, advertising URL http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:184)
[2019-07-24 19:44:02,063] INFO Advertised URI: http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:288)
[2019-07-24 19:44:02,063] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45)
[2019-07-24 19:44:02,074] INFO Kafka version: 5.3.0-ce (org.apache.kafka.common.utils.AppInfoParser:117)
[2019-07-24 19:44:02,074] INFO Kafka commitId: a0f453a8a5e8c137 (org.apache.kafka.common.utils.AppInfoParser:118)
[2019-07-24 19:44:02,074] INFO Kafka startTimeMs: 1563977642074 (org.apache.kafka.common.utils.AppInfoParser:119)
[2019-07-24 19:44:02,186] INFO JsonConverterConfig values:
converter.type = key
schemas.cache.size = 1000
schemas.enable = false
(org.apache.kafka.connect.json.JsonConverterConfig:347)
[2019-07-24 19:44:02,187] INFO JsonConverterConfig values:
converter.type = value
schemas.cache.size = 1000
schemas.enable = false
(org.apache.kafka.connect.json.JsonConverterConfig:347)
[2019-07-24 19:44:02,198] INFO Kafka Connect standalone worker initialization took 22850ms (org.apache.kafka.connect.cli.ConnectStandalone:100)
[2019-07-24 19:44:02,198] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)
[2019-07-24 19:44:02,198] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:91)
[2019-07-24 19:44:02,198] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:182)
[2019-07-24 19:44:02,199] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:58)
[2019-07-24 19:44:02,218] INFO Worker started (org.apache.kafka.connect.runtime.Worker:187)
[2019-07-24 19:44:02,218] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:93)
[2019-07-24 19:44:02,219] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:188)
[2019-07-24 19:44:02,336] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365)
[2019-07-24 19:44:02,336] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
[2019-07-24 19:44:02,338] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:149)
Jul 24, 2019 7:44:02 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored.
Jul 24, 2019 7:44:02 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored.
Jul 24, 2019 7:44:02 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored.
[2019-07-24 19:44:02,934] INFO HV000001: Hibernate Validator 5.1.3.Final (org.hibernate.validator.internal.util.Version:27)
Jul 24, 2019 7:44:03 PM org.glassfish.jersey.internal.Errors logErrors
WARNING: The following warnings have been detected: WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
[2019-07-24 19:44:03,082] INFO Started o.e.j.s.ServletContextHandler@1214d23c{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:855)
[2019-07-24 19:44:03,083] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:236)
[2019-07-24 19:44:03,083] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)
[2019-07-24 19:44:03,163] INFO AbstractConfig values:
(org.apache.kafka.common.config.AbstractConfig:347)
[2019-07-24 19:44:03,172] INFO ConnectorConfig values:
config.action.reload = restart
connector.class = com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector
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 = sftp_streaming
tasks.max = 1
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2019-07-24 19:44:03,173] INFO EnrichedConnectorConfig values:
config.action.reload = restart
connector.class = com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector
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 = sftp_streaming
tasks.max = 1
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2019-07-24 19:44:03,173] INFO Creating connector sftp_streaming of type com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector (org.apache.kafka.connect.runtime.Worker:246)
[2019-07-24 19:44:03,180] INFO Instantiated connector sftp_streaming with version null of type class com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector (org.apache.kafka.connect.runtime.Worker:249)
[2019-07-24 19:44:03,183] ERROR WorkerConnector{id=sftp_streaming} Error while starting connector (org.apache.kafka.connect.runtime.WorkerConnector:119)
java.lang.ExceptionInInitializerError
at com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector.start(FtpSourceConnector.scala:31)
at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:111)
at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:136)
at org.apache.kafka.connect.runtime.WorkerConnector.transitionTo(WorkerConnector.java:196)
at org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:252)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.startConnector(StandaloneHerder.java:293)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:209)
at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:115)
**Caused by: java.lang.NullPointerException: inStream parameter is null**
at java.base/java.util.Objects.requireNonNull(Objects.java:246)
at java.base/java.util.Properties.load(Properties.java:403)
at com.eneco.trading.kafka.connect.ftp.source.GitRepositoryState$.(GitRepositoryState.scala:7)
at com.eneco.trading.kafka.connect.ftp.source.GitRepositoryState$.(GitRepositoryState.scala)
... 8 more
[2019-07-24 19:44:03,185] INFO Finished creating connector sftp_streaming (org.apache.kafka.connect.runtime.Worker:268)
[2019-07-24 19:44:03,186] INFO Skipping update of connector sftp_streaming since it is not running (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:325)
[2019-07-24 19:44:03,187] INFO Created connector sftp_streaming (org.apache.kafka.connect.cli.ConnectStandalone:112)
