fix: Fixes graalvm issues with micronaut-kafka not working if you set…

… a value for errorStrategy (#658)
micronaut-projects · Feb 9, 2023 · 5ce50c7 · 5ce50c7
1 parent d1f9622
commit 5ce50c7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/kafka/src/main/java/io/micronaut/configuration/kafka/processor/KafkaConsumerProcessor.java b/kafka/src/main/java/io/micronaut/configuration/kafka/processor/KafkaConsumerProcessor.java
@@ -1069,9 +1069,9 @@ private ConsumerState(String clientId, String groupId, OffsetStrategy offsetStra
             redelivery = kafkaListener.isTrue("redelivery");
 
             AnnotationValue<ErrorStrategy> errorStrategyAnnotation = kafkaListener.getAnnotation("errorStrategy", ErrorStrategy.class).orElse(null);
-            errorStrategy = errorStrategyAnnotation == null ? ErrorStrategyValue.NONE : kafkaListener.get("errorStrategy", ErrorStrategy.class)
-                    .map(ErrorStrategy::value)
-                    .orElse(ErrorStrategyValue.NONE);
+            errorStrategy = errorStrategyAnnotation != null
+                ? errorStrategyAnnotation.getRequiredValue(ErrorStrategyValue.class)
+                : ErrorStrategyValue.NONE;
 
             if (isRetryErrorStrategy(errorStrategy)) {
                 Duration retryDelay = errorStrategyAnnotation.get("retryDelay", Duration.class)