From 6a23cf95f59880eaa025268367d58fbd494854e8 Mon Sep 17 00:00:00 2001
From: jmaxwell <jmaxwell@theice.com>
Date: Wed, 31 Jan 2018 10:18:37 -0600
Subject: [PATCH] 1202 Inconsistent use of this.prefix in
 AvroSchemaRegistryClientMessageConverter.resolveSchemaForWriting

Resolves #1202
Resolves #1203
---
 .../schema/avro/AvroSchemaRegistryClientMessageConverter.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 fb783e614..eac187ab2 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
@@ -252,8 +252,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;