kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robin Moffatt (Jira)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors
Date Thu, 10 Oct 2019 15:11:00 GMT
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

View raw message