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
