diff --git a/api/src/main/java/io/kafbat/ui/serdes/builtin/sr/SchemaRegistrySerde.java b/api/src/main/java/io/kafbat/ui/serdes/builtin/sr/SchemaRegistrySerde.java index d6f7a3699..c395e9984 100644 --- a/api/src/main/java/io/kafbat/ui/serdes/builtin/sr/SchemaRegistrySerde.java +++ b/api/src/main/java/io/kafbat/ui/serdes/builtin/sr/SchemaRegistrySerde.java @@ -80,7 +80,8 @@ public void autoConfigure(PropertyResolver kafkaClusterProperties, kafkaClusterProperties.getProperty("schemaRegistrySsl.keystoreLocation", String.class).orElse(null), kafkaClusterProperties.getProperty("schemaRegistrySsl.keystorePassword", String.class).orElse(null), kafkaClusterProperties.getProperty("ssl.truststoreLocation", String.class).orElse(null), - kafkaClusterProperties.getProperty("ssl.truststorePassword", String.class).orElse(null) + kafkaClusterProperties.getProperty("ssl.truststorePassword", String.class).orElse(null), + kafkaClusterProperties.getProperty("ssl.verifySsl", Boolean.class).orElse(true) ), kafkaClusterProperties.getProperty("schemaRegistryKeySchemaNameTemplate", String.class).orElse("%s-key"), kafkaClusterProperties.getProperty("schemaRegistrySchemaNameTemplate", String.class).orElse("%s-value"), @@ -106,7 +107,8 @@ public void configure(PropertyResolver serdeProperties, serdeProperties.getProperty("keystoreLocation", String.class).orElse(null), serdeProperties.getProperty("keystorePassword", String.class).orElse(null), kafkaClusterProperties.getProperty("ssl.truststoreLocation", String.class).orElse(null), - kafkaClusterProperties.getProperty("ssl.truststorePassword", String.class).orElse(null) + kafkaClusterProperties.getProperty("ssl.truststorePassword", String.class).orElse(null), + kafkaClusterProperties.getProperty("ssl.verifySsl", Boolean.class).orElse(true) ), serdeProperties.getProperty("keySchemaNameTemplate", String.class).orElse("%s-key"), serdeProperties.getProperty("schemaNameTemplate", String.class).orElse("%s-value"), @@ -136,7 +138,8 @@ private static SchemaRegistryClient createSchemaRegistryClient(List urls @Nullable String keyStoreLocation, @Nullable String keyStorePassword, @Nullable String trustStoreLocation, - @Nullable String trustStorePassword) { + @Nullable String trustStorePassword, + boolean verifySsl) { Map configs = new HashMap<>(); if (username != null && password != null) { configs.put(BASIC_AUTH_CREDENTIALS_SOURCE, "USER_INFO"); @@ -166,6 +169,11 @@ private static SchemaRegistryClient createSchemaRegistryClient(List urls keyStorePassword); } + if (!verifySsl) { // TODO block above + configs.put(SchemaRegistryClientConfig.CLIENT_NAMESPACE + SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, + ""); + } + return new CachedSchemaRegistryClient( urls, 1_000,