lct45 commented on a change in pull request #9875:
URL: https://github.com/apache/kafka/pull/9875#discussion_r556146003
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##########
@@ -749,9 +749,11 @@ void runOnce() {
// multiple iterations with reasonably large max.num.records and
hence is less vulnerable to outliers
taskManager.recordTaskProcessRatio(totalProcessLatency, now);
- log.info("Processed {} total records, ran {} punctuators, and
committed {} total tasks " +
- "for active tasks {} and standby tasks {}",
- totalProcessed, totalPunctuated, totalCommitted,
taskManager.activeTaskIds(), taskManager.standbyTaskIds());
+ // Don't log summary if no new records were processed to avoid
spamming logs for low-traffic topics
+ if (totalProcessed > 0 || totalPunctuated > 0 || totalCommitted >
0) {
+ log.info("Processed {} total records, ran {} punctuators, and
committed {} total tasks",
Review comment:
I have a similar question here, other than that LGTM
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
