我正在以分发模式启动kafka connect,但出现以下错误。这在我的另一个dev集群上工作得很好,但是,我只在我的生产集群中得到这个错误。
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
暂无答案!
目前还没有任何答案,快来回答吧!