在kafka连接失败的情况下配置debezium mysql连接器
我正在使用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"
}
}'
共有1个答案
来自curl的错误表明您的请求是通过Squid http代理进行的。你确定它被正确地转发了吗？你能直接打个电话吗？
-
使用SpringBoot、Java1.8、云配置服务器 我试图使用这个application.yml片段访问git回购。但是找不到主机密钥。 地址在我的knowHosts文件中： 堆栈跟踪： 你知道为什么这样不行吗？
-
我尝试为我的数据创建带有“转换”的插件到kafka-connect，并将其与不同的接收器连接器一起使用。当我安装插件时，kafka-connect看不到我的类。 我使用kafka connect maven插件创建了我的捆绑包zip。使用confluent hub（来自本地文件）的安装已成功。 所有文件都已解压，我的工作者属性已更新插件。路径。我在分布式模式下运行connect，并尝试从包中创建带
-
我正在尝试使用Kafka连接接收器将文件从Kafka写入HDFS。 我的属性看起来像： 有什么建议吗？
-
我们有一个从rdbms读取并放入kafka的源连接器。它使用带有avro模式的模式注册表。我分别在kafka连接日志和模式注册表日志中发现以下异常。 1. 0 因此，基本上模式注册表在注册模式之前将偏移量移动到最新，然后超时500毫秒。 我的问题是这个。 > 我怎样才能找到为什么它不能从kafka读取？ 源连接器任务是否重新启动或轮询一个连接器的失败任务的数据？因为在日志的后面部分，我看到了这一点
-
错误：无法启动连接：错误：WebSocket无法连接。在服务器上找不到连接，endpoint可能不是信号器endpoint，服务器上不存在连接ID，或者存在阻止WebSocket的代理。如果有多台服务器，请检查是否启用了粘性会话。 WebSocketTransport.js:49WebSocket连接到“ws：//xxxxxx/生产/网络服务/集线器/spreadhub”失败： Angular.t