1

我正在使用 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"
      }
}'

卡夫卡连接日志：

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 apach e.kafka.connect.runtime.distributed.DistributedHerder:852) Sep 12, 2018 7:38:17 AM 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 中的（子）资源方法 serverInfo。

[2018-09-12 07:38:18,213] 信息开始 oejsServletContextHandler@21d1b321{/, null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744) [2018-09-12 07:38:18,223 ] INFO Started http_8083@6ec65b5e{HTTP/1.1}{0.0.0.0:8083 } (org.eclipse.jetty.server.ServerConnector:266) [2018-09-12 07:38:18,223] INFO Started @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/ , 广告网址http://localhost:8083/(org.apache.kafka.connect.runtime.rest.Re stServer:207) [2018-09-12 07:38:18,223] 信息 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)

4

1 回答 1

0

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

于 2018-09-13T04:02:23.513 回答