Hi
I am having this issue, and not sure what to do,
i am doing oracle (connect) -> kafka -> transform -> kafka -> opentsdb (connect),
and i cannot get the opentsdb connect work, so i am trying now
oracle (connect) -> kafka -> process (calling rest api on opentsdb)
i am doing all these in the code (connect + stream), when i am running the new code
13:02| INFO | WorkerSinkTask.java 261 | WorkerSinkTask{id=tsdb-sink-0} Committing offsets
13:02| DEBUG | ConsumerCoordinator.java 544 | Group connect-tsdb-sink committed offset 0 for partition METRIC_DATA-0
13:02| DEBUG | WorkerSinkTask.java 183 | Finished WorkerSinkTask{id=tsdb-sink-0} offset commit successfully in 16 ms
13:02| ERROR | WorkerTask.java 142 | Task tsdb-sink-0 threw an uncaught and unrecoverable exception
org.apache.kafka.connect.errors.DataException: Failed to deserialize data to Avro:
at io.confluent.connect.avro.AvroConverter.toConnectData(AvroConverter.java:109)
at org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:357)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:226)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:170)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.util.concurrent.FutureTask.run(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
tsdb-sink-0, i dont have tsdb-sink anymore, but somehow it is still there,
any idea? i even renamed the stream name, a different topic, still the same,
Thanks
Shannon