文章/答案/技术大牛

发布

社区首页 >问答首页 >使用尚未使用的名称创建kafka连接器

问使用尚未使用的名称创建kafka连接器
EN

Stack Overflow用户

提问于 2019-01-08 13:45:00

回答 2查看 1K关注 0票数 3

当我试图创建一个名称已经通过rest调用使用的kafka连接器时，我遇到了一个错误：

{"error_code":409，“消息”：“连接器测试已存在”}

我想绕开这个错误，例如，在创作卡夫卡主题的时候，

./kafka-topics **--if-not-exists**  --create --zookeeper localhost:2181 --replication-factor  1 --partitions 1  --topic test

在创建卡夫卡连接器时，我们有类似--if-not-exists的东西吗？

apache-kafka

apache-kafka-connect

回答 2

Stack Overflow用户

发布于 2019-01-08 15:36:42

我喜欢使用PUT方法对配置端点进行处理，如下所示：

curl -i -X PUT -H "Accept:application/json" -H  "Content-Type:application/json" \
http://localhost:8083/connectors/my-connector-name/config -d "@my-connector-config.json"

该行为是在不存在的情况下创建，否则更新，请参阅本文中的文档：https://docs.confluent.io/current/connect/references/restapi.html#put--connectors-(string-name)-config。

请注意，您的json有效负载不需要包含name和config，而只需要包含文档示例中的config内容。

票数 3

Stack Overflow用户

发布于 2019-01-08 14:02:42

没有直接的方法，但您可以始终使用自定义脚本来容纳验证。您可以使用REST查询活动连接器，如下所示。

 curl localhost:8083/connectors  // will return the active connectors on worker
 ["local-file-sink1", "db-sink1"]

获得活动连接器的名称后，可以根据连接器属性验证该名称是否已经使用。

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/54093168

复制

相似问题

问使用尚未使用的名称创建kafka连接器
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用尚未使用的名称创建kafka连接器EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用尚未使用的名称创建kafka连接器
EN