From 7d5b538009ebd8dbceefd2d1fac9ff5c02cf6334 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 d8efadf25..8a9873b3b 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
@@ -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;