无法创建CamelSalesforcesourceSourceConnector：ResolveEndpointFailedException

Question

背景：我是一名Python开发人员，从未使用过Java。

Camel Salesforce Source Connector： v3.20.6（我已经尝试过 3.21.0 和 4.0.0，我面临着同样的问题）
卡夫卡：v3.6.1

问题：

尝试为我的 kafka 实例创建 CamelSalesforcesourceSourceConnector，但失败并出现异常 ResolveEndpointFailedException。我尝试了使用 Kafka 的 REST API 创建连接器的几种变体。

变化 1：

{“名称”：“sf-source-connector”，“配置”：{“tasks.max”：“1”，“connector.class”：“org.apache.camel.kafkaconnector.salesforcesource.CamelSalesforcesourceSourceConnector”，“ key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.storage.StringConverter", "camel.kamelet.salesforce-source.query" ：“从帐户中选择*”，“camel.kamelet.salesforce-source.topicName”：“/data/AccountChangeEvent”，“camel.kamelet.salesforce-source.loginUrl”：“https://login.salesforce.com/ ", "camel.kamelet.salesforce-source.clientId": "", "camel.kamelet.salesforce-source.clientSecret": "", "camel.kamelet.salesforce-source.userName": "", "camel. kamelet.salesforce-source.password": "", "camel.kamelet.salesforce-source.notifyForOperationCreate": "true", "camel.kamelet.salesforce-source.notifyForOperationUpdate": "true", "camel.kamelet.salesforce -source.notifyForOperationDelete": "true", "camel.kamelet.salesforce-source.notifyForOperationUndelete": "true", "camel.source.endpoint.rawPayload": "true", "camel.kamelet.salesforce-source.operation ": "订阅", "主题": "camelsfstream" } }

故障异常总结-

以 - org.apache.kafka.connect.errors.ConnectException 开头：无法创建和启动 Camel 上下文 在 org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:184) 结尾为 - 原因为：java.lang.IllegalArgumentException：/data/AccountChangeEvent 在 org.apache.camel.component.salesforce.internal.OperationName.fromValue(OperationName.java:128) 在 org.apache.camel.component.salesforce.SalesforceComponent.createEndpoint(SalesforceComponent.java:303) 在 org.apache.camel.support.DefaultComponent.createEndpoint(DefaultComponent.java:171) 在org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint（AbstractCamelContext.java:975）

关键问题 -

IllegalArgumentException：/data/AccountChangeEvent

变化 2 -

在我的连接器中，我替换了主题名称： "camel.kamelet.salesforce-source.topicName": "subscribe:/data/AccountChangeEvent"

异常以 Failed to create and start Camel context 开始，但最终异常变为 -

原因：有 1 个参数无法在端点上设置。检查 uri 参数是否拼写正确并且它们是端点的属性。未知参数=[{操作名称=订阅}]

如果没有操作名称，我无法覆盖端点 url 来测试上述变体，而且我也知道订阅是默认设置。因此，即使我从 json 中删除该属性，也没有什么区别。

另一方面，端点以 local-salesforce-1:// 开头，# 递增 - 是这样吗？我找不到任何属性来改变这一点。我想它最终会被取代。

提出了 github 问题 - https://github.com/apache/camel-kafka-connector/issues/1587

Answer 1

找到了我自己的 github 问题中作为评论描述的解决方法 - https://github.com/apache/camel-kafka-connector/issues/1587#issuecomment-1903530176

总之，在将操作名称添加为 kamelet 属性并将操作添加为主题中的前缀之前，已移至连接器版本 3.18.x。确实遇到了更多问题，其解决方案在我的 github 评论中进行了描述（上面链接）。