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;