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