We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
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)
The text was updated successfully, but these errors were encountered:
No branches or pull requests
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:
The text was updated successfully, but these errors were encountered: