From 44a03c8cb6607306dc159228e2946af887bfaa9c Mon Sep 17 00:00:00 2001 From: Eric Wenk Date: Fri, 19 Jan 2024 15:03:16 +0100 Subject: [PATCH] limit log message No longer logging the whole schema on a restClientException --- .../kafka/serializers/AbstractKafkaAvroSerializer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); }