Copilot commented on code in PR #23791:
URL: https://github.com/apache/kafka/pull/23791#discussion_r4269258924
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##########
@@ -2204,7 +2204,7 @@ public static void executeAndMaybeSwallow(final boolean
clean,
e -> {
throw e;
},
- e -> log.debug("Ignoring error in unclean {}", name));
+ e -> log.error("Error closing unclean {}", name));
Review Comment:
The exception is still omitted from this ERROR log, so the timed-out
commit/abort failure is reported without its type, message, or stack trace.
Pass `e` as the trailing SLF4J argument so the new log provides the diagnostic
information described by the change.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
