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 [email protected] < [email protected]> 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 > > >
