From 0c1c0fd409b6f7269861dc0241b432ec1a4237f8 Mon Sep 17 00:00:00 2001
From: Stephane Paulus <spaulus@alpian.com>
Date: Mon, 9 Sep 2024 09:08:36 +0200
Subject: [PATCH] Adding kafka properties to KafkaProtobufDeserializer, to be
 able to execute schema registry rules.

---
 .../java/org/akhq/repositories/SchemaRegistryRepository.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);