diff --git a/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java b/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java
index c99b649a6..1fea2f1e4 100644
--- a/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java
+++ b/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java
@@ -327,7 +327,7 @@ public Deserializer getKafkaProtoDeserializer(String clusterId) {
             if (schemaRegistryType == SchemaRegistryType.TIBCO) {
                 throw new IllegalArgumentException("Configured schema registry type was 'tibco', but TIBCO PROTOBUF client is not supported");
             } else {
-                deserializer = new KafkaProtobufDeserializer(this.kafkaModule.getRegistryClient(clusterId));
+                deserializer = new KafkaProtobufDeserializer(this.kafkaModule.getRegistryClient(clusterId), this.kafkaModule.getConnection(clusterId).getProperties());
             }
 
             this.kafkaProtoDeserializers.put(clusterId, deserializer);