Fix schema repository

Dockerfile

@@ -15,6 +15,7 @@ WORKDIR /app
 # Create user
 RUN useradd -ms /bin/bash akhq
 COPY --chown=akhq:akhq docker /
+RUN chmod +x /usr/local/bin/docker-entrypoint.sh
 ENV MICRONAUT_CONFIG_FILES=/app/application.yml
 # Use the 'akhq' user
 USER akhq

helm/akhq/templates/ingress.yaml

@@ -42,7 +42,7 @@ spec:
 	{{- range $ingressPaths }}
           - path: {{ . }}
             {{- if eq (include "akhq.ingress.apiVersion" $) "networking.k8s.io/v1" }}
-            pathType: {{ $.Values.ingress.pathType | default "ImplementationSpecific" }}
+            pathType: {{ $.Values.ingress.pathType | default "Prefix" }}
             {{- end }}
             backend:
               {{- if eq (include "akhq.ingress.apiVersion" $) "networking.k8s.io/v1" }}

helm/akhq/values.yaml

@@ -137,15 +137,15 @@ service:
     # cloud.google.com/load-balancer-type: "Internal"
 
 ingress:
-  enabled: false
+  enabled: true
   ingressClassName: ""
   annotations: {}
     # kubernetes.io/ingress.class: nginx
     # kubernetes.io/tls-acme: "true"
   labels: {}
   paths:
     - /
-  pathType: "ImplementationSpecific"
+  pathType: "Prefix"
   hosts:
     - akhq.demo.com
   tls: []

src/main/java/org/akhq/repositories/SchemaRegistryRepository.java

@@ -1,5 +1,9 @@
 package org.akhq.repositories;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+
 import com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryKafkaDeserializer;
 import com.amazonaws.services.schemaregistry.utils.AWSSchemaRegistryConstants;
 import com.amazonaws.services.schemaregistry.utils.AvroRecordType;
@@ -41,6 +45,10 @@
 public class SchemaRegistryRepository extends AbstractRepository {
     public static final int ERROR_NOT_FOUND = 40401;
 
+    private static final Logger log =
+        LoggerFactory.getLogger(SchemaRegistryRepository.class);
+
+
     @Inject
     private KafkaModule kafkaModule;
 
@@ -66,9 +74,12 @@ private List<Schema> toSchemasLatestVersion(List<String> subjectList, String clu
                     try {
                         return getLatestVersion(clusterId, s);
                     } catch (RestClientException | IOException e) {
-                        throw new RuntimeException(e);
+                        log.warn("Unable to fetch latest version for schema {}" , s , e );
+                        return null;
                     }
                 })
+                .filter(Objects::nonNull)
+
                 .collect(Collectors.toList());
     }