alcudiaMV
commented
10 months ago The root cause is the format of my url :
https://ksql402xxxxxxxAn url without a port for KSQL cannot work with the AKHQ version 0.24.0, a DNS alone is not enough
Class org.akhq.modules.KafkaModule line 363 https://github.com/tchiotludo/akhq/blob/0.24.0/src/main/java/org/akhq/modules/KafkaModule.java
private final Map<String, Map<String, Client>> ksqlDbClient = new HashMap<>();
public Map<String, Client> getKsqlDbClient(String clusterId) throws InvalidClusterException {
if (!this.clusterExists(clusterId)) {
throw new InvalidClusterException("Invalid cluster '" + clusterId + "'");
}
if (!this.ksqlDbClient.containsKey(clusterId)) {
Connection connection = this.getConnection(clusterId);
if (connection.getKsqldb() != null && !connection.getKsqldb().isEmpty()) {
Map<String, Client> mapKsqlDbs = new HashMap<>();
connection.getKsqldb().forEach(ksqlDb -> {
URIBuilder uri = URIBuilder.fromString(ksqlDb.getUrl().toString());
ClientOptions options = ClientOptions.create()
.setHost(uri.getHost().get())
.setPort(uri.getPort().get())
.setUseTls(ksqlDb.isUseTls())
.setUseAlpn(ksqlDb.isUseAlpn())
.setVerifyHost(ksqlDb.isVerifyHost());
if (ksqlDb.getBasicAuthUsername() != null && ksqlDb.getBasicAuthPassword() != null) {
options.setBasicAuthCredentials(ksqlDb.getBasicAuthUsername(), ksqlDb.getBasicAuthPassword());
}
Client client = Client.create(options);
mapKsqlDbs.put(ksqlDb.getName(), client);
});
this.ksqlDbClient.put(clusterId, mapKsqlDbs);
}
}
return this.ksqlDbClient.get(clusterId);
}}
aonamrata
FrankMormino
Hi,
I have deployed version 0.24, ksqldb is available with this configuration :
But when I click on the instance I got an error :
If you have a sugestion :-)
Thanks