abbccdda commented on a change in pull request #8632:
URL: https://github.com/apache/kafka/pull/8632#discussion_r422332367
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##########
@@ -732,15 +732,16 @@ Task taskForInputPartition(final TopicPartition
partition) {
return tasks.values().stream().filter(t -> !t.isActive());
}
+ // For testing only.
+ int commitAll() {
+ return commit(tasks.values());
+ }
+
Review comment:
I see your point and thought about it, but I feel a little bit reluctant
to remove it for the reason that it is indeed a handy call to make for testing
purpose :)
----------------------------------------------------------------
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
