search

SINTEF-9012 / kafka-mqtt-source-connector

A connector plugin to use with Kafka's Connect API. It can be configured to map any topic from an mqtt broker to any topic on the Kafka broker. The connector can be configured to use SSL in communication with the mqtt broker.
MIT License
24 stars 17 forks source link

I need help #4

Closed mkuiwu closed 4 years ago

mkuiwu commented 4 years ago

problem

1. My system environment

Mint19.3

jdk1.8

2.

The first run was successful. When I restarted the computer, running connect-distributed.sh would get stuck. I do n’t know why.I completely followed the introductory tutorial and my configuration is correct.

root@jiayuan:/home/jiayuan# jps
23936 ConnectDistributed
22082 Kafka
21476 QuorumPeerMain
28454 Jps

Below is the output of running connect-distributed.sh , I cannot open port 19005.

[2020-04-12 19:46:30,128] 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=/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../logs, -Dlog4j.configuration=file:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../config/connect-log4j.properties
    jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 1.8.0_231, 25.231-b11
    jvm.classpath = .:/home/jiayuan/apps/jdk1.8.0_231/lib:/home/jiayuan/apps/jdk1.8.0_231/jre/lib:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/activation-1.1.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/aopalliance-repackaged-2.5.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/argparse4j-0.7.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/audience-annotations-0.5.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/commons-cli-1.4.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/commons-lang3-3.8.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-api-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-basic-auth-extension-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-file-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-json-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-mirror-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-mirror-client-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-runtime-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/connect-transforms-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/guava-20.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/hk2-api-2.5.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/hk2-locator-2.5.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/hk2-utils-2.5.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-annotations-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-core-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-databind-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-dataformat-csv-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-datatype-jdk8-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-jaxrs-base-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-jaxrs-json-provider-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-module-jaxb-annotations-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-module-paranamer-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jackson-module-scala_2.13-2.10.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jakarta.activation-api-1.2.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jakarta.annotation-api-1.3.4.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jakarta.inject-2.5.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jakarta.ws.rs-api-2.1.5.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/javassist-3.22.0-CR2.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/javax.servlet-api-3.1.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/javax.ws.rs-api-2.1.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jaxb-api-2.3.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jersey-client-2.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jersey-common-2.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jersey-container-servlet-2.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jersey-container-servlet-core-2.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jersey-hk2-2.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jersey-media-jaxb-2.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jersey-server-2.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-client-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-continuation-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-http-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-io-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-security-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-server-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-servlet-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-servlets-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jetty-util-9.4.20.v20190813.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/jopt-simple-5.0.4.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka_2.13-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka_2.13-2.4.1-sources.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka-clients-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka-log4j-appender-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka-streams-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka-streams-examples-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka-streams-scala_2.13-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka-streams-test-utils-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/kafka-tools-2.4.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/log4j-1.2.17.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/lz4-java-1.6.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/maven-artifact-3.6.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/metrics-core-2.2.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-buffer-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-codec-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-common-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-handler-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-resolver-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-transport-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-transport-native-epoll-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/netty-transport-native-unix-common-4.1.45.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/osgi-resource-locator-1.0.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/paranamer-2.8.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/plexus-utils-3.2.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/reflections-0.9.11.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/rocksdbjni-5.18.3.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/scala-collection-compat_2.13-2.1.2.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/scala-java8-compat_2.13-0.9.0.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/scala-library-2.13.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/scala-logging_2.13-3.9.2.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/scala-reflect-2.13.1.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/slf4j-api-1.7.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/slf4j-log4j12-1.7.28.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/snappy-java-1.1.7.3.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/validation-api-2.0.1.Final.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/zookeeper-3.5.7.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/zookeeper-jute-3.5.7.jar:/home/jiayuan/apps/kafka_2.13-2.4.1/bin/../libs/zstd-jni-1.4.3-1.jar
    os.spec = Linux, amd64, 5.3.0-46-generic
    os.vcpus = 4
 (org.apache.kafka.connect.runtime.WorkerInfo:71)
[2020-04-12 19:46:30,136] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:90)
[2020-04-12 19:46:30,158] INFO Loading plugin from: /usr/share/java/ridl-6.0.7.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,262] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/ridl-6.0.7.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,263] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:30,263] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:30,263] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:30,264] INFO Loading plugin from: /usr/share/java/servlet-api-4.0.1.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,275] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/servlet-api-4.0.1.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,276] INFO Loading plugin from: /usr/share/java/unoloader-6.0.7.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,282] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/unoloader-6.0.7.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,282] INFO Loading plugin from: /usr/share/java/hsqldbutil1.8.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,301] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/hsqldbutil1.8.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,301] INFO Loading plugin from: /usr/share/java/jsp-api-2.3.4-SNAPSHOT.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,309] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/jsp-api-2.3.4-SNAPSHOT.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,310] INFO Loading plugin from: /usr/share/java/websocket-api.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,316] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/websocket-api.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,317] INFO Loading plugin from: /usr/share/java/libintl.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,319] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/libintl.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,319] INFO Loading plugin from: /usr/share/java/servlet-api.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,330] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/servlet-api.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,330] INFO Loading plugin from: /usr/share/java/gettext.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,336] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/gettext.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,337] INFO Loading plugin from: /usr/share/java/jurt.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,346] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/jurt.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,347] INFO Loading plugin from: /usr/share/java/jurt-6.0.7.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,357] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/jurt-6.0.7.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,357] INFO Loading plugin from: /usr/share/java/websocket-client-api.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,362] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/websocket-client-api.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,362] INFO Loading plugin from: /usr/share/java/unoil-6.0.7.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,465] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/unoil-6.0.7.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,465] INFO Loading plugin from: /usr/share/java/hsqldbutil1.8.0-1.8.0.10+dfsg.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,479] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/hsqldbutil1.8.0-1.8.0.10+dfsg.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,479] INFO Loading plugin from: /usr/share/java/servlet-api-3.1.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,486] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/servlet-api-3.1.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,487] INFO Loading plugin from: /usr/share/java/juh.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,494] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/juh.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,495] INFO Loading plugin from: /usr/share/java/hsqldb1.8.0-1.8.0.10+dfsg.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,535] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/hsqldb1.8.0-1.8.0.10+dfsg.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,536] INFO Loading plugin from: /usr/share/java/hsqldb1.8.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,574] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/hsqldb1.8.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,574] INFO Loading plugin from: /usr/share/java/ridl.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,591] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/ridl.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,592] INFO Loading plugin from: /usr/share/java/el-api-3.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,597] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/el-api-3.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,597] INFO Loading plugin from: /usr/share/java/websocket-api-1.1.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,613] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/websocket-api-1.1.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,613] INFO Loading plugin from: /usr/share/java/unoil.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,691] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/unoil.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,692] INFO Loading plugin from: /usr/share/java/websocket-client-api-1.1.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,696] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/websocket-client-api-1.1.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,696] INFO Loading plugin from: /usr/share/java/jsp-api-2.3.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:30,701] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/jsp-api-2.3.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:30,701] INFO Loading plugin from: /usr/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
ERROR StatusLogger Log4j2 could not find a logging implementation. Please add log4j-core to the classpath. Using SimpleLogger to log to the console...
[2020-04-12 19:46:31,252] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:31,252] INFO Added plugin 'com.sintef.asam.MqttSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:31,252] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:31,252] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:31,252] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:31,252] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-04-12 19:46:31,253] INFO Loading plugin from: /usr/share/java/el-api.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:31,259] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/el-api.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:31,259] INFO Loading plugin from: /usr/share/java/juh-6.0.7.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:31,265] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/juh-6.0.7.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:31,265] INFO Loading plugin from: /usr/share/java/java_uno.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:31,268] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/java_uno.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:31,268] INFO Loading plugin from: /usr/share/java/jsp-api.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:31,274] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/jsp-api.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:31,275] INFO Loading plugin from: /usr/share/java/unoloader.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:31,278] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/unoloader.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:31,278] INFO Loading plugin from: /usr/share/java/websocket-api-1.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:31,282] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/websocket-api-1.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-04-12 19:46:31,282] INFO Loading plugin from: /usr/share/java/el-api-3.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-04-12 19:46:31,287] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/el-api-3.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)

At this point it was completely stuck and I couldn't open port 19005