[ https://issues.apache.org/jira/browse/KAFKA-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Randall Hauch resolved KAFKA-9018. ---------------------------------- Resolution: Fixed > 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 > Affects Versions: 2.5.0, 2.4.1 > Reporter: Robin Moffatt > Assignee: Mario Molina > Priority: Minor > Fix For: 2.7.0 > > > 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. > Example message that user will get (in this case caused by reading non-Avro > data with the Avro converter) > {code:java} > 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!{code} -- This message was sent by Atlassian Jira (v8.3.4#803005)