Robin Moffatt created KAFKA-9018:
------------------------------------
Summary: Kafka Connect - throw clearer exceptions on serialisation
errors
Key: KAFKA-9018
URL: https://issues.apache.org/jira/browse/KAFKA-9018
Project: Kafka
Issue Type: Improvement
Components: KafkaConnect
Reporter: Robin Moffatt
When Connect fails on a deserialisation error, it doesn't show if that's the
*key or value* that's thrown the error, nor does it give the user any
indication of the *topic/partition/offset* of the message. Kafka Connect should
be improved to return this information.
Caused by: org.apache.kafka.connect.errors.DataException: Failed to deserialize
data for topic sample_topic to Avro:
at
io.confluent.connect.avro.AvroConverter.toConnectData(AvroConverter.java:110)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.lambda$convertAndTransformRecord$1(WorkerSinkTask.java:487)
at
org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128)
at
org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162)
... 13 more
Caused by: org.apache.kafka.common.errors.SerializationException: Error
deserializing Avro message for id -1
Caused by: org.apache.kafka.common.errors.SerializationException: Unknown magic
byte!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
