Hello,
We still need to focus on the servicenow kafka connector. We are going
ahead and trying to test as much as we can, but for third party service
like servicenow is a bit complicated.
Il giorno lun 7 dic 2020 alle ore 19:13 simon.pe...@sbb.ch <
simon.pe...@sbb.ch> ha scritto:
> Hi folks
>
> We would like to use the Service Now Connector, to connect Kafka to
> Service Now.
> We are using the Camel Version 0.6.0.
> However, there seems to be an error, when sending the data to the server.
>
> "org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask
> due to unrecoverable exception.\n\tat
> org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:568)\n\tat
>
> org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:326)\n\tat
>
> org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:228)\n\tat
>
> org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:196)\n\tat
>
> org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:184)\n\tat
>
> org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234)\n\tat
>
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat
> java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat
> java.lang.Thread.run(Thread.java:748)\nCaused by:
> org.apache.kafka.connect.errors.ConnectException:
> Exchange delivery has failed!\n\tat
> org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:152)\n\tat
>
> org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:546)\n\t...
> 10 more\nCaused by: java.lang.IllegalArgumentException: Unable to
> process
> exchange\n\tat
> org.apache.camel.component.servicenow.AbstractServiceNowProcessor.process(AbstractServiceNowProcessor.java:74)\n\tat
>
> org.apache.camel.support.BaseSelectorProducer.process(BaseSelectorProducer.java:36)\n\tat
>
> org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66)\n\tat
>
> org.apache.camel.processor.SendDynamicProcessor.lambda$process$0(SendDynamicProcessor.java:195)\n\tat
>
> org.apache.camel.impl.engine.DefaultProducerCache.doInAsyncProducer(DefaultProducerCache.java:317)\n\tat
>
> org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:180)\n\tat
>
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:404)\n\tat
>
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)\n\tat
>
> org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)\n\tat
>
> org.apache.camel.processor.Pipeline.process(Pipeline.java:147)\n\tat
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:288)\n\tat
>
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:67)\n\tat
>
> org.apache.camel.processor.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:217)\n\tat
>
> org.apache.camel.processor.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:111)\n\tat
>
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)\n\tat
>
> org.apache.camel.processor.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)\n\tat
>
> org.apache.camel.impl.engine.DefaultProducerCache.send(DefaultProducerCache.java:189)\n\tat
>
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:175)\n\tat
>
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:147)\n\tat
>
> org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:149)\n\t..."
>
> This is the configuration:
> class: CamelServicenowSinkConnector
> config:
> camel.sink.endpoint.userName: service
> camel.sink.endpoint.password: ***
> camel.sink.endpoint.table: incident
> camel.sink.path.instanceName: entw
> camel.sink.endpoint.resource: table
> camel.sink.endpoint.release: HELSINKI
> camel.sink.endpoint.basicPropertyBinding: false
> topics: kafka.connector.servicenow
> value.converter: org.apache.kafka.connect.storage.StringConverter
>
>
> The payload is String value = "{\"short_description\":\"test incident
> kafka\",\"description\":\"this is a test\"}";
>
> Are we missing something?
>
> Cheers Simon
>
>
>
