时间戳

首页 > 解决方案 > Kafka Connect REST 请求中出现意外字符

curl - Kafka Connect REST 请求中出现意外字符

问题描述

我在独立模式下成功运行 kafka connect，但是当涉及到分布式模式时，我在调用 rest api 发布连接器时遇到错误。

这是 POST 调用 curl -X POST -H "Content-Type: application/json" -H "Accept: application/json" --data <path to json>/mysql_dist.json http://xxxxxxxxxx:8083/connectors/

当我执行上述调用时，我得到错误。

<html>
<head>
<meta http-equiv="Content-Type" content="text/html;charset=ISO-8859-1"/>
<title>Error 500 </title>
</head>
<body>
<h2>HTTP ERROR: 500</h2>
<p>Problem accessing /connectors/. Reason:
<pre>    Request failed.</pre></p>
<hr /><i><small>Powered by Jetty://</small></i>
</body>
</html>

在此处输入图像描述

这是 MySQL-sourceconnecter json 文件

{
  "name": "mysql-connector",  
  "config": {
    "connector.class": "io.debezium.connector.mysql.MySqlConnector", 
    "database.hostname": "localhost", 
    "database.port": "3306", 
    "database.user": "root", 
    "database.password": "admin", 
    "database.server.id": "42", 
    "database.server.name": "demo", 
    "database.whitelist": "mydbb", 
    "database.history.kafka.bootstrap.servers": "xxxxxxxxxx:6667", 
    "database.history.kafka.topic": "mydbb.student", 
    "include.schema.changes": "true",
    "key.converter":"org.apache.kafka.connect.json.JsonConverter",
    "database.history.store.only.monitored.tables.ddl": "false",
    "key.converter.schemas.enable": "false",
    "value.converter.schemas.enable": "false",
    "transforms": "unwrap",
    "transforms.unwrap.type": "io.debezium.transforms.UnwrapFromEnvelope",
    "transforms.unwrap.drop.tombstones": "true",
    "transforms.unwrap.delete.handling.mode": "rewrite",
    "transforms.unwrap.drop.deletes": "true"
  }
}

标签： curlapache-kafkaapache-kafka-connect

解决方案

推荐阅读