diff --git a/avro-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaAvroSerializer.java b/avro-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaAvroSerializer.java index 51702240659..dba9f53276a 100644 --- a/avro-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaAvroSerializer.java +++ b/avro-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaAvroSerializer.java @@ -173,7 +173,7 @@ protected byte[] serializeImpl( // ClassCastException, etc throw new SerializationException("Error serializing Avro message", e); } catch (RestClientException e) { - throw toKafkaException(e, restClientErrorMsg + schema); + throw toKafkaException(e, restClientErrorMsg); } finally { postOp(object); }