From c275231ce1e9d53ea253e4ced11ec68055abcd51 Mon Sep 17 00:00:00 2001
From: "sookyom.kim" <sookyom.kim@wesang.com>
Date: Thu, 19 Oct 2023 16:53:54 +0900
Subject: [PATCH] Add option to use custom schema registry image for
 kafkacluster

---
 trivup/clusters/KafkaCluster.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/trivup/clusters/KafkaCluster.py b/trivup/clusters/KafkaCluster.py
index 8cae55c..b4ca731 100755
--- a/trivup/clusters/KafkaCluster.py
+++ b/trivup/clusters/KafkaCluster.py
@@ -197,7 +197,7 @@ def __init__(self, **kwargs):
         # Create SchemaRegistry if enabled
         if bool(self.conf.get('with_sr', False)):
             self.sr = SchemaRegistryApp(
-                self.cluster, {'version': self.conf.get('cp_version')})
+                self.cluster, {'version': self.conf.get('cp_version'), 'image': self.conf.get('sr_image')})
             self.env['SR_URL'] = self.sr.get('url')
 
         # Create librdkafka client configuration