【发布时间】：2018-11-15 18:22:13
【问题描述】：
我正在尝试使用以下方式启动 kafka-connect：
connect-distributed /etc/schema-registry/connect-avro-distributed.properties
，然后我得到：
[2017-02-15 12:45:35,962] INFO Instantiated task mysql-adventureworks-source-0 with version 3.1.2 of type io.confluent.connect.jdbc.source.JdbcSourceTask (org.apache.kafka.connect.runtime.Worker:264)
[2017-02-15 12:45:35,963] ERROR Failed to start task mysql-adventureworks-source-0 (org.apache.kafka.connect.runtime.Worker:280)
org.apache.kafka.common.config.ConfigException: Missing Schema registry url!
at io.confluent.connect.avro.AvroConverter.configure(AvroConverter.java:64)
at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:268)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:757)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startWork(DistributedHerder.java:750)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.handleRebalanceCompleted(DistributedHerder.java:708)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:204)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:174)
at java.lang.Thread.run(Thread.java:745)
显示架构 url。我也尝试过使用：
connect-distributed /etc/kafka/connect-distributed.properties
，它使用json格式，但我得到了同样的错误。
有什么想法吗？
【问题讨论】：
-
看起来错误是在启动连接器任务时而不是工作人员本身。您为连接器配置发送什么？否则，也许发布您的属性文件？
-
您是否尝试使用开箱即用的属性文件启动 Kafka Connect 分布式模式？
bin/connect-distributed.sh config/connect-distributed.properties -
connect-distributed.properties 文件包含以下属性：key.converter=io.confluent.connect.avro.AvroConverter key.converter.schema.registry.url=localhost:8081value.converter=io。 confluent.connect.avro.AvroConverter value.converter.schema.registry.url=localhost:8081 如果您使用“key.converter”作为 AvroConverter 并且没有给出“key.converter.schema.registry.url”，同样的价值。可能会出现此问题。
标签： apache-kafka apache-kafka-connect