diff --git a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaRegistryClientMessageConverter.java b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaRegistryClientMessageConverter.java index 86e2163ba..27128453f 100644 --- a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaRegistryClientMessageConverter.java +++ b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaRegistryClientMessageConverter.java @@ -184,7 +184,7 @@ public class AvroSchemaRegistryClientMessageConverter extends AbstractAvroMessag + schema.getName()); } this.schemaRegistryClient.register(toSubject(schema), AVRO_FORMAT, - schema.toString(true)); + schema.toString()); if (this.logger.isInfoEnabled()) { this.logger.info("Schema " + schema.getName() + " registered with id " + schema);