运行kafka连接分布式模式时地址已被使用

Question

我通过发出“./bin/confluent start”命令启动了融合套件。然后我使用 kafka connect 将 kafka 数据汇入 mysql。

通过执行以下命令，我可以在独立模式下很好地运行 kafka connect：

./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/adstats-jdbc-sink.properties

然后我关闭上面的命令并通过命令切换到分布式模式：

./bin/connect-distributed ./etc/schema-registry/connect-avro-distributed.properties ./etc/kafka-connect-jdbc/adstats-jdbc-sink.properties

它报告了以下异常：

[2018-08-09 14:51:56,951] 错误无法启动连接 (org.apache.kafka.connect.cli.ConnectDistributed:108) org.apache.kafka.connect.errors.ConnectException: 无法启动 REST 服务器org.apache.kafka.connect.runtime.rest.RestServer.start(RestServer.java:214) 在 org.apache.kafka.connect.runtime.Connect.start(Connect.java:53) 在 org.apache.kafka。 connect.cli.ConnectDistributed.main(ConnectDistributed.java:106) 由：java.net.BindException：地址已在 sun.nio.ch.Net.bind0(Native Method) at sun.nio.ch.Net 使用。绑定（Net.java:433）在 sun.nio.ch.Net.bind（Net.java:425）

怎么了？如何切换到使用 kafka connect 分布式模式？谢谢！

Answer 1

当您运行时，confluent start您已经以分布式模式启动了 Kafka Connect。因此，您可以使用该实例，也可以在属性文件中为要运行的第二个实例定义新的 REST 端口。

无论哪种方式，您都可以将接收器配置提交到分布在 REST 上的 Kafka Connect，而不是在启动时将其作为属性参数传递（与独立的不同）。