use constant for retry number

camunda · Jul 2, 2024 · d1718a6 · d1718a6
1 parent 8c7fd66
commit d1718a6
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/connectors/kafka/src/main/java/io/camunda/connector/kafka/inbound/KafkaExecutable.java b/connectors/kafka/src/main/java/io/camunda/connector/kafka/inbound/KafkaExecutable.java
@@ -74,13 +74,15 @@ public KafkaExecutable(
     this.retryPolicy = retryConfig;
   }
 
+  private static final int INFINITE_RETRIES = -1;
+
   public KafkaExecutable() {
     this(
         KafkaConsumer::new,
         RetryPolicy.builder()
             .handle(Exception.class)
             .withDelay(Duration.ofSeconds(30))
-            .withMaxAttempts(-1)
+            .withMaxAttempts(INFINITE_RETRIES)
             .build());
   }