aliehsaeedii commented on code in PR #20693:
URL: https://github.com/apache/kafka/pull/20693#discussion_r2432279248
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##########
@@ -742,13 +742,19 @@ public boolean isProcessable(final long wallClockTime) {
if (hasPendingTxCommit) {
// if the task has a pending TX commit, we should just retry the
commit but not process any records
// thus, the task is not processable, even if there is available
data in the record queue
+ if (log.isDebugEnabled()) {
Review Comment:
What is the reason for calling `isDebugEnabled()` only at this specific
location and not in the former debug leveling loggings?
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##########
@@ -742,13 +742,19 @@ public boolean isProcessable(final long wallClockTime) {
if (hasPendingTxCommit) {
// if the task has a pending TX commit, we should just retry the
commit but not process any records
// thus, the task is not processable, even if there is available
data in the record queue
+ if (log.isDebugEnabled()) {
Review Comment:
What is the reason for calling `isDebugEnabled()` only at this specific
location and not in the former debug level loggings?
--
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]
