当我试图创建一个名为kafka的连接器时，它已经通过rest调用使用了，我得到了一个错误消息，
{“错误代码”：409，“消息”：“连接器测试已经存在”}
我想绕过这个错误，例如，在创建Kafka主题时，我们有如下内容，
./kafka-topics**--if-not-exists**--create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test我们有类似的吗 --if-not-exists 创建Kafka连接器时？
2条答案
按热度按时间luaexgnf1#
没有直接的方法，但是您可以始终使用自定义脚本来适应验证。您可以使用restapi查询活动连接器，如下所示。
获取活动连接器的名称后，可以根据连接器属性进行验证，以查看该名称是否已被使用。
j2qf4p5b2#
我喜欢这样做我们使用
PUT方法，如下所示：其行为是在不存在的情况下创建，否则将更新，更多信息请参见以下文档：https://docs.confluent.io/current/connect/references/restapi.html#put--连接器-（字符串名称）-配置
请注意，您的
json有效载荷不需要包含name以及config，但只有config文档示例中的内容。