1202 Inconsistent use of this.prefix in AvroSchemaRegistryClientMessageConverter.resolveSchemaForWriting

Resolves #1202
Resolves #1203
This commit is contained in:
jmaxwell
2018-01-31 10:18:37 -06:00
committed by Soby Chacko
parent 48ff2cc620
commit 7d5b538009

View File

@@ -250,8 +250,8 @@ public class AvroSchemaRegistryClientMessageConverter extends AbstractAvroMessag
if (headers instanceof MutableMessageHeaders) {
headers.put(MessageHeaders.CONTENT_TYPE,
"application/vnd." + schemaReference.getSubject() + ".v"
+ schemaReference.getVersion() + "+avro");
"application/" + this.prefix + "." + schemaReference.getSubject()
+ ".v" + schemaReference.getVersion() + "+avro");
}
return schema;