bbejeck commented on code in PR #23791:
URL: https://github.com/apache/kafka/pull/23791#discussion_r4271742600
##########
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:
yeah I get that but leaving at debug is not great either, we spent a lot of
time tracking down the current issue because there was nothing in the logs.
I've put at at `WARN` which follows the general pattern in `TaskManager`
--
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]
