无法注册kafka雪花连接器的架构
分布式服务已成功启动：[2021 10月17日18:04:29693]信息已启动o.e.j.s.ServletContextHandler@1422ac7f{/，null，AVAILABLE}（org.html" target="_blank">eclipse.jetty.server.handler.ContextHandler:916）[2021 10月17日18:04:29693]初始化信息REST资源；服务器已启动并准备好处理请求（org.apache.kafka.connect.runtime.rest.RestServer:319）[2021 10月17日18:04:29693]信息kafka connect已启动（org.apache.kafka.connect.runtime.connect:57）
但无法创建模式注册表：curl-X PUT-H“内容类型：应用程序/json”--数据{“name”：“file stream demo distributed”，“config”：{“connector.class”：“com.snowflake.kafka.connector.SnowflakeSinkConnector”，“topic”：“demo-2-distributed”，“file”：/home/ramakrishnakonda/kafka_2.13-2.8.0/config/connect distributed.properties“}}”http://localhost:8083/connectors{“error_code”：405，“message”：“不允许HTTP 405方法”}
请帮帮忙
共有2个答案
curl -X POST "http://localhost:8083/connectors" -H "Content- type:application/json" --data
"{
"name":"file-stream-demo-distributed",
"config":{
"connector.class":"com.snowflake.kafka.connector.SnowflakeSinkConnector",
"tasks.max":"1",
"topics":"demo-2-distributed",
"buffer.count.records":"10000",
"buffer.flush.time":"60",
"buffer.size.bytes":"5000000",
"snowflake.url.name":"XXXXXXXX.XXXXXXXXX.snowflakecomputing.com:443",
"snowflake.user.name":"kafka_connector_user_1",
"snowflake.private.key":"XXXXXXXXXXXXXXXXXXX+XXXXXXXXXXXXXXXXXXXXXXXXXXXXX,
"snowflake.database.name":"KAFKA_DB",
"snowflake.schema.name":"KAFKA_SCHEMA",
"key.converter":"org.apache.kafka.connect.storage.StringConverter",
"key.converter.schemas.enable":"true", "value.converter":"com.snowflake.kafka.connector.records.SnowflakeJsonConverter",
"value.converter:schemas.enable":"true",
"value.converter.schema.registry.url":"http://localhost:8081"
}
}"
使用POST而不是PUT，如本例所示：
$ 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":"connect-test" }}' http://localhost:8083/connectors
-
我正在使用 3 个服务器集群进行 Kafka 配置，使用 Snowflake 连接器 REST API 将数据推送到 Snowflake 数据库：所有这些都是在 AWS 上运行的 3 个不同的虚拟机 1.在这种情况下，我们是否需要3个kafka单独的服务器zookeeper服务需要在集群中启动和运行，否则只有1个就足够了，就像它需要在所有3个服务器zookerper服务中执行一样，它是否需要不同的
-
我试图运行Kafka服务与Zookeper，Kafdrop和模式注册表，我使它的工作安装Kafka，Zookeper和Kadrop在一个容器，然后安装合流模式注册表在另一个（与自己的Kafka，Zoowatch，Ksql服务器和Rest代理），然而尝试要使kafdrop读取模式注册表不工作，所以现在我想只安装一个容器与Kafka，Zoowatch，Kafdrop和模式注册表，即使一切都成功安装，模
-
我正在尝试在启用SSL的Kafka集群中注册MySql Debezium连接器。我为此目的使用的卷曲是： Debezium无法创建数据库。历史记录主题，它将失败，并出现以下错误： 美化错误：
-
我使用以下代码运行模式注册服务器: 使用docker组件部署后，我得到以下错误： Kafka 在本地运行（它不在泊坞窗中运行），顺便说一句，kafka 服务器属性具有以下特性： broker.id=0 侦听器=PLAINTEXT://localhost:9092 监听器.security.protocol.map=纯文本：纯文本，SSL：SSL，SASL_PLAINTEXT：SASL_PLAINT
-
我有一个docker容器运行AWS弹性容器服务（Fargate）中的confluentinc/cp模式注册表：5.5.0。只有一个容器正在运行。通过该模式注册表获取当前注册模式的API调用正在工作（例如，
-
下载confluent open source 3.3后在命令行做一个简单的实验： 合流启动-启动所有服务时不会出现任何可见错误：