From eb33d7a19b005e89abaf1abe0bd6be9e7daa033b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jose=20Antonio=20I=C3=B1igo=20Garrido?= <jainigo@profile.es>
Date: Sat, 8 Jun 2019 12:40:36 +0200
Subject: [PATCH] Support for multiple event types when using GenericRecord

---
 .../stream/schema/avro/AvroSchemaServiceManagerImpl.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaServiceManagerImpl.java b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaServiceManagerImpl.java
index 9b95f7fb5..79b073226 100644
--- a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaServiceManagerImpl.java
+++ b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/avro/AvroSchemaServiceManagerImpl.java
@@ -135,6 +135,11 @@ public class AvroSchemaServiceManagerImpl implements AvroSchemaServiceManager {
 					reader = new GenericDatumReader<>(schema);
 				}
 			}
+			else {
+				if (writerSchema != null) {
+					reader = new GenericDatumReader(writerSchema);
+				}
+			}
 		}
 		else {
 			reader = new ReflectDatumReader(type);