You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by "simon.peyer@sbb.ch" <si...@sbb.ch> on 2020/12/07 16:54:55 UTC

Service Now Connector Working Example

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

Re: Service Now Connector Working Example

Posted by Andrea Cosentino <an...@gmail.com>.
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.peyer@sbb.ch <
simon.peyer@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
>
>
>