在分布式模式下启动Kafka Connect时出错

问题描述

我正在以分发模式启动Kafka connect，但收到以下错误。在其他开发集群上也可以正常工作，但是，只有在生产集群中才出现此错误。

ERROR Stopping due to error (org.apache.kafka.connect.cli.Connectdistributed:84)
java.lang.IllegalArgumentException: "uri" parameter is null.
    at org.glassfish.jersey.uri.internal.JerseyUriBuilder.uri(JerseyUriBuilder.java:104)
    at org.glassfish.jersey.uri.internal.JerseyUriBuilder.uri(JerseyUriBuilder.java:48)
    at javax.ws.rs.core.UriBuilder.fromUri(UriBuilder.java:83)
    at org.apache.kafka.connect.runtime.rest.RestServer.advertisedUrl(RestServer.java:347)
    at org.apache.kafka.connect.runtime.rest.RestServer.initializeServer(RestServer.java:218)
    at org.apache.kafka.connect.cli.Connectdistributed.startConnect(Connectdistributed.java:99)
    at org.apache.kafka.connect.cli.Connectdistributed.main(Connectdistributed.java:78)

以下是我正在使用的connect.properties文件的内容

key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=false
value.converter.schemas.enable=false
task.shutdown.graceful.timeout.ms=10000
offset.flush.interval.ms=60000
offset.flush.timeout.ms=5000
plugin.path=<directory path>
bootstrap.servers=<kafka-address>
group.id=Kafka_Connect_Group1
offset.storage.topic=<topic name>
offset.storage.replication.factor=2
config.storage.topic=<topic name>
config.storage.replication.factor=2
status.storage.topic=D<topic name>
status.storage.replication.factor=2
rest.host.name=
rest.port=20831
rest.advertised.host.name=
rest.advertised.port=20831

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafka apache-kafka-connect