fix(registry): defaultToGlobal query to avoid schema registry error log

close #1098
tchiotludo · May 26, 2022 · dbef78e · dbef78e
1 parent 676d89a
commit dbef78e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java b/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java
@@ -220,7 +220,7 @@ public Schema.Config getConfig(String clusterId, String subject) throws IOExcept
         try {
             return new Schema.Config(this.kafkaModule
                 .getRegistryRestClient(clusterId)
-                .getConfig(subject)
+                .getConfig(Map.of(), subject, true)
             );
         } catch (RestClientException exception) {
             if (exception.getStatus() != 404) {