You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The HTTP connector I had configured for my Aiven Kafka service started failing after I configured a 'Flatten' transform (org.apache.kafka.connect.transforms.Flatten$Value) on the connector.
I kept getting the following exception:
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:611)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:333)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:234)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:203)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:188)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:243)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: org.apache.kafka.connect.errors.DataException: Record value must be String, Schema Struct or HashMap, but class java.util.LinkedHashMap is given
at io.aiven.kafka.connect.http.converter.RecordValueConverter.convert(RecordValueConverter.java:44)
at io.aiven.kafka.connect.http.recordsender.BatchRecordSender.createRequestBody(BatchRecordSender.java:77)
at io.aiven.kafka.connect.http.recordsender.BatchRecordSender.send(BatchRecordSender.java:60)
at io.aiven.kafka.connect.http.HttpSinkTask.put(HttpSinkTask.java:97)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581)
... 10 more
I emphasize that this only occurred after applying the "Flatten" transform on the value.
The HTTP connector I had configured for my Aiven Kafka service started failing after I configured a 'Flatten' transform (
org.apache.kafka.connect.transforms.Flatten$Value
) on the connector.I kept getting the following exception:
I emphasize that this only occurred after applying the "Flatten" transform on the value.
Here is the configuration I was using:
The text was updated successfully, but these errors were encountered: