diff --git a/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java b/src/main/java/org/akhq/repositories/SchemaRegistryRepository.java index 00e0d13d3..d7d9a81cf 100644 --- 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) {