使用 Kafka Connect Distributed 创建连接器返回 500 错误答案

【问题标题】：Creating a connector with Kafka Connect Distributed returning 500 error使用 Kafka Connect Distributed 创建连接器返回 500 错误
【发布时间】：2017-04-20 13:23:14
【问题描述】：

我正在努力从 Camus 迁移到 Kafka Connect。我正在研究 Kafka Connect 的实现，特别关注分布式模式。我能够在我假设与我的 Kafka 集群通信的本地机器上成功启动一个工作程序。我还可以运行两个返回正确 JSON 的 GET 命令，例如 / 和 /connector-plugins。但是，当我尝试发布创建连接器的命令时，我收到 500 错误和超时。具体来说，我使用这个命令来 POST 进行测试：

curl -X POST -H "Content-Type: application/json" --data '{"name": "local-file-sink", "config": {"connector.class":"FileStreamSinkConnector", "tasks.max":"1", "file":"test.sink.txt", "topics":"myTopic" }}' localhost:8083/connectors

最终我得到了这样的回应：

{"error_code": 500, "message": "Request timed out"}

我不知道发生了什么。我的 Kafka Connect 分布式工作人员的日志显示了这一点：

[2016-12-05 14:34:32,436] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:22:34:32 +0000] "GET /connector-plugins HTTP/1.1" 200 315  2 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:05:25,422] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:05:25 +0000] "GET /connector-plugins HTTP/1.1" 200 315  3 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:05:28,389] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:05:28 +0000] "GET /connector-plugins HTTP/1.1" 200 315  2 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:07:38,644] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:06:08 +0000] "GET /connectors HTTP/1.1" 500 48  90003 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:07:44,450] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:07:44 +0000] "GET /connector-plugins HTTP/1.1" 200 315  1 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:13:06,703] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:11:36 +0000] "POST /connectors HTTP/1.1" 500 48  90003 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:15:38,506] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:14:08 +0000] "POST /connectors HTTP/1.1" 500 48  90005 (org.apache.kafka.connect.runtime.rest.RestServer:60)

您可以在哪里看到错误代码和命令。

我想我的主要问题是：

如何更好地调试 Kafka Connect，以便尝试解决此问题？
我做的有什么明显错误的吗？
是否有任何关于让 Kafka Connect 分布式工作器和连接器运行的分步文档或博客文章？我还没有真正看到任何甚至最佳实践类型的文档？也许我只是太早采用者了。

我期待收到社区的回复，并感谢您的帮助！

【问题讨论】：

你可以检查你的broker集群是否有broker.id=0的broker

标签： apache-kafka apache-kafka-connect

【解决方案1】：

我能够解决这个问题。我在客户端和集群上都运行 Confluent Platform 3.0.1。我将集群升级到 Confluent Platform 3.1.1，并将客户端升级到新版本。我能够启动集群。此外，您可以通过阅读 Kafka 用户组上关于同一问题的此线程来了解有关调试 Kafka Connect 的更多信息：

http://mail-archives.apache.org/mod_mbox/kafka-users/201612.mbox/%3cA22A7CDA-21D5-4E58-BD38-3796065FD6A5@trulia.com%3e

希望对其他人有所帮助。

【讨论】：