From 2f7bc6ced71a8247147286e649b827d8e83449fd Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Thu, 21 Mar 2024 14:07:27 +0100 Subject: [PATCH] Forward streams errors if cause is recoverable --- .../src/main/java/com/bakdata/kafka/ErrorUtil.java | 3 +-- 1 file changed, 1 insertion(+), 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 index ffedd38..3fbc6ad 100644 --- 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. *

Non-recoverable Kafka errors are: *