Skip to content

Commit 01c68fc

Browse files
authored
Expose user exception thrown during rebalance (#2667)
As a user, I do not want exception my exception be effectively ignored by framework by logging them on debug level
1 parent 9619aba commit 01c68fc

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/ConsumerAwareRebalanceListener.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ default void onPartitionsRevokedBeforeCommit(Consumer<?, ?> consumer, Collection
5252
onPartitionsRevoked(partitions);
5353
}
5454
catch (Exception e) { // NOSONAR
55-
LOGGER.debug(e, "User method threw exception");
55+
LOGGER.error(e, "User method threw exception");
5656
}
5757
}
5858

@@ -76,7 +76,7 @@ default void onPartitionsLost(Consumer<?, ?> consumer, Collection<TopicPartition
7676
onPartitionsLost(partitions);
7777
}
7878
catch (Exception e) { // NOSONAR
79-
LOGGER.debug(e, "User method threw exception");
79+
LOGGER.error(e, "User method threw exception");
8080
}
8181
}
8282

@@ -91,7 +91,7 @@ default void onPartitionsAssigned(Consumer<?, ?> consumer, Collection<TopicParti
9191
onPartitionsAssigned(partitions);
9292
}
9393
catch (Exception e) { // NOSONAR
94-
LOGGER.debug(e, "User method threw exception");
94+
LOGGER.error(e, "User method threw exception");
9595
}
9696
}
9797

0 commit comments

Comments
 (0)