Ziauddin135 opened a new issue, #1505: URL: https://github.com/apache/camel-kafka-connector/issues/1505
am using camel-salesforce-create-sink-kafka-connector to sink data from kafka ==> salesforce sObject salesforce sink connector plugins downloaded from [https://camel.apache.org/camel-kafka-connector/next/reference/index.html](http://url/) connector config:- ``` { "name": "camel-sf-sink-1", "config": { "connector.class":"org.apache.camel.kafkaconnector.salesforcecreatesink.CamelSalesforcecreatesinkSinkConnector", "tasks.max":1, "topics":"topic_8108", "camel.kamelet.salesforce-create-sink.clientId":"<client-id>", "camel.kamelet.salesforce-create-sink.clientSecret":"<client-secret>", "camel.kamelet.salesforce-create-sink.userName":"<salesforce-username>", "key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.json.JsonConverter", "key.converter.schemas.enable": "false", "value.converter.schemas.enable": "false", "camel.kamelet.salesforce-create-sink.password":"<salesforce-pwd-token>", "camel.kamelet.salesforce-create-sink.loginUrl":"https://test.salesforce.com";, "camel.kamelet.salesforce-create-sink.sObjectName":"Kafka_Sink_event__e", "schemas.enable":false } } ``` but i am getting this error even though i am using correct salesforce user and credentials _org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:969)\n\t... 31 more\nCaused by: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id salesforce-create-sink not found in locations: classpath:/kamelets\n\tat org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:414)\n\tat org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.track(KameletComponent.java:441)\n\t... 39 more\nCaused by: org.apache.camel.FailedToCreateRouteException: Failed to create route salesforce-create-sink-20 at: >>> To[{{local-salesforce}}:createSObject?rawPayload=true&sObjectName={{sObjectName}}] <<< in route: Route(salesforce-create-sink-20)[From[kamelet://source?route... because of Failed to resolve endpoint: local-salesforce-4://createSObject?rawPayload=true&sObjectName=Kafka_Sink_event__e due to: Cannot auto create component: local-salesforce-4\n\tat org.apache.camel.r eifier.RouteReifier.doCreateRoute(RouteReifier.java:240)\n\tat org.apache.camel.reifier.RouteReifier.createRoute(RouteReifier.java:74)\n\tat org.apache.camel.impl.DefaultModelReifierFactory.createRoute(DefaultModelReifierFactory.java:49)\n\tat org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:862)\n\tat org.apache.camel.impl.DefaultModel.addRouteDefinitions(DefaultModel.java:189)\n\tat org.apache.camel.impl.DefaultModel.addRouteDefinition(DefaultModel.java:195)\n\tat org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:428)\n\tat org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:307)\n\tat org.apache.camel.impl.DefaultCamelContext.addRouteFromTemplate(DefaultCamelContext.java:448)\n\tat org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:402)\n\t... 40 more\nCaused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endp oint: local-salesforce-4://createSObject?rawPayload=true&sObjectName=Kafka_Sink_event__e due to: Cannot auto create component: local-salesforce-4\n\tat org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:985)\n\tat org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:867)\n\tat org.apache.camel.support.CamelContextHelper.resolveEndpoint(CamelContextHelper.java:123)\n\tat org.apache.camel.reifier.SendReifier.resolveEndpoint(SendReifier.java:45)\n\tat org.apache.camel.reifier.SendReifier.createProcessor(SendReifier.java:37)\n\tat org.apache.camel.reifier.ProcessorReifier.makeProcessor(ProcessorReifier.java:847)\n\tat org.apache.camel.reifier.ProcessorReifier.addRoutes(ProcessorReifier.java:588)\n\tat org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:236)\n\t... 49 more\nCaused by: org.apache.camel.RuntimeCamelException: Cannot auto create component: local-salesforce-4\n\tat org.apache.camel.im pl.engine.AbstractCamelContext.getComponent(AbstractCamelContext.java:646)\n\tat org.apache.camel.impl.engine.AbstractCamelContext.getComponent(AbstractCamelContext.java:601)\n\tat org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:943)\n\t... 56 more\nCaused by: org.apache.camel.RuntimeCamelException: org.apache.camel.component.salesforce.api.SalesforceException: {errors:[{\"errorCode\":\"invalid_grant\",\"message\":\"Login error code:[invalid_grant] description:[authentication failure]\",\"fields\":null}],statusCode:400}\n\tat org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:66)\n\tat org.apache.camel.support.service.BaseService.doFail(BaseService.java:413)\n\tat org.apache.camel.support.service.BaseService.fail(BaseService.java:342)\n\tat org.apache.camel.support.service.BaseService.start(BaseService.java:132)\n\tat org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:113)\n\tat org.apache.camel.component.salesforce.SalesforceComponent.doStart(SalesforceComponent.java:423)\n\tat org.apache.camel.support.service.BaseService.start(BaseService.java:119)\n\tat org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:113)\n\tat org.apache.camel.impl.engine.AbstractCamelContext.startService(AbstractCamelContext.java:3667)\n\tat org.apache.camel.impl.engine.AbstractCamelContext.getComponent(AbstractCamelContext.java:640)\n\t... 58 more\nCaused by: org.apache.camel.component.salesforce.api.SalesforceException: {errors:[{\"errorCode\":\"invalid_grant\",\"message\":\"Login error code:[invalid_grant] description:[authentication failure]\",\"fields\":null}],statusCode:400}\n\tat org.apache.camel.component.salesforce.internal.SalesforceSession.parseLoginResponse(SalesforceSession.java:283)\n\tat org.apache.camel.component.salesforce.internal.SalesforceSession.login(SalesforceSession.java:126)\n\tat org.apache.camel.component.salesforce.internal.Sa lesforceSession.doStart(SalesforceSession.java:357)\n\tat org.apache.camel.support.service.BaseService.start(BaseService.java:119)\n\t... 64 more\n_ **Please help what i have misconfigured here?** -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
