Forward streams errors if cause is recoverable

bakdata · Mar 21, 2024 · 2f7bc6c · 2f7bc6c
1 parent 72ccda6
commit 2f7bc6c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/error-handling-core/src/main/java/com/bakdata/kafka/ErrorUtil.java b/error-handling-core/src/main/java/com/bakdata/kafka/ErrorUtil.java
@@ -75,8 +75,7 @@ public static boolean isRecoverable(final Exception e) {
 
     /**
      * Check if an exception is thrown by Kafka, i.e., located in package {@code org.apache.kafka.common.errors} or
-     * {@code org.apache.kafka.streams.errors}, and is
-     * recoverable.
+     * {@code org.apache.kafka.streams.errors}, and is recoverable.
      * <p>Non-recoverable Kafka errors are:
      * <ul>
      *     <li>{@link RecordTooLargeException}