使用kafka连接配置debezium mysql连接器失败

Question

我正在使用 kafka 2.0 和 kafka connect 在分布式模式下运行并尝试配置 debezium mysql 连接器但得到 错误

HTTP/1.1 500 Internal Server Error
Server: squid
Mime-Version: 1.0
Date: Wed, 12 Sep 2018 06:14:40 GMT
Content-Type: text/html;charset=utf-8
Content-Length: 2869
X-Squid-Error: ERR_CANNOT_FORWARD 0
X-Cache: MISS from lnoi3proxy02.one.steria.dom
X-Cache-Lookup: MISS from lnoi3proxy02.one.steria.dom:8080
Connection: keep-alive

来电：

curl -i -X POST -H "Accept:application/json" \  
    -H  "Content-Type:application/json" http://localhost:8083/connectors/ \
    -d '{ name": "inventory-connector",
    "config": {
        "connector.class":"io.debezium.connector.mysql.MySqlConnector",
        "database.hostname":"localhost",
        "database.port":"3306",
        "database.user":"root",
        "database.password":"Password@123",
        "database.dbname":"inventory",
         "database.server.id":"41228",
        "database.server.name":"customer",
        "database.whitelist":"inventory",
        "database.history.kafka.bootstrap.servers":"localhost:9092",
        "database.history.kafka.topic":"schema-changes.inventory",
       "include.schema.changes":"true"
      }
}'

kafka 连接日志：

INFO [Worker clientId=connect-1, groupId=connect-cluster] 已成功加入第 7 代组 (org.apache.kafka.clients.consum er.internals.AbstractCoordinator:409) [2018-09-12 07:38:17,370] INFO 加入群组并获得分配：Assignment{error =0, leader='connect-1-63af40e1-da48-4055-99f8-8799582ba5aa', leaderUrl='http://l ocalhost :8083/', offset=-1, connectorIds=[], taskIds=[]} (org.apache.kafka.conne ct.runtime.distributed.DistributedHerder:1194) [2018-09-12 07:38:17,373] INFO 使用配置偏移量 -1 启动连接器和任务（org.apache.kafka.connect.runtime.distributed.DistributedHerder:842） [2018-09-12 07:38:17,373] 信息已完成启动连接器和任务（org.apach e.kafka.connect.runtime.distributed.DistributedHerder:852） 2018 年 9 月 12 日上午 7:38:17 org.glassfish.jersey.internal.Errors logErrors 警告：已检测到以下警告：警告：org.apache.kafka.connect.runtime.rest.resources.Connect orsResource 中的（子）资源方法 createConnector 包含空路径注释。 警告：org.apache.kafka.connect.run time.rest.resources.ConnectorsResource 中的（子）资源方法 listConnectors 包含空路径注释。 警告：org.apache.kafka.conne ct.runtime.rest.resources.ConnectorPluginsResource 中的（子）资源方法 listConnectorPlugins 包含空路径注释。 警告：org.apache.kafka.connect.runtime .rest.resources.RootResource 中的（子）资源方法 serverInfo 包含空路径注释。

[2018-09-12 07:38:18,213] 信息开始 o.e.j.s.ServletContextHandler@21d1b321{/, null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744) [2018-09-12 07:38:18,223] 信息开始 http_8083@6ec65b5e{HTTP/1.1}{0.0.0.0:8083 } (org.eclipse.jetty.server.ServerConnector:266) [2018-09-12 07:38:18,223] 信息开始 @15360ms (org.eclipse.jetty.server.Server:379) [2018-09-12 07:38:18,223] 信息广告 URI：http://localhost:8083/ (org.apach e.kafka.connect.runtime.rest.RestServer:248) [2018-09-12 07:38:18,223] INFO REST 服务器在 http://127.0.0.1:8083/ 监听，广告 URL http://localhost:8083/ (org.apache.kafka.connect.runtime.rest.Re stServer:207) [2018-09-12 07:38:18,223] INFO Kafka Connect 已启动（org.apache.kafka.connect.r untime.Connect:55） [2018-09-12 07:43:16,612] 信息集群 ID：8oMHsNLASgubK4CBagB-dw (org.apache.ka fka.clients.Metadata:265) [2018-09-12 07:43:17,052] 信息集群 ID：8oMHsNLASgubK4CBagB-dw (org.apache.ka fka.clients.Metadata:265) [2018-09-12 07:43:17,289] 信息集群 ID：8oMHsNLASgubK4CBagB-dw (org.apache.ka fka.clients.Metadata:265)

Answer 1

来自 curl 的错误表明您的请求是通过 Squid http 代理进行的。您确定它已正确转发吗？可以直接打电话吗？