Add DekRegistry to SR properties for easier access

confluentinc · Jun 27, 2024 · 07ea0e0 · 07ea0e0
1 parent 12aaf72
commit 07ea0e0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dek-registry/src/main/java/io/confluent/dekregistry/storage/DekRegistry.java b/dek-registry/src/main/java/io/confluent/dekregistry/storage/DekRegistry.java
@@ -98,6 +98,8 @@ public class DekRegistry implements Closeable {
 
   private static final Logger log = LoggerFactory.getLogger(DekRegistry.class);
 
+  public static final String KEY = "dekRegistry";
+
   public static final int LATEST_VERSION = DekRegistryClient.LATEST_VERSION;
   public static final int MIN_VERSION = 1;
   public static final byte[] EMPTY_AAD = new byte[0];
@@ -135,6 +137,7 @@ public DekRegistry(
   ) {
     try {
       this.schemaRegistry = (KafkaSchemaRegistry) schemaRegistry;
+      this.schemaRegistry.properties().put(KEY, this);
       this.schemaRegistry.addUpdateRequestHandler(new EncryptionUpdateRequestHandler());
       this.metricsManager = metricsManager;
       this.config = new DekRegistryConfig(schemaRegistry.config().originalProperties());