diff --git a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/QualifiedSubjectNamingStrategy.java b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/QualifiedSubjectNamingStrategy.java index 2d103e82b..d068eb6c3 100644 --- a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/QualifiedSubjectNamingStrategy.java +++ b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/QualifiedSubjectNamingStrategy.java @@ -26,7 +26,7 @@ public class QualifiedSubjectNamingStrategy implements SubjectNamingStrategy { @Override public String toSubject(Schema schema) { - return schema.getFullName(); + return schema.getFullName().toLowerCase(); } }