Good catch. The deliberation was that even though "there is no data processed", not "there is no active tasks" as the original check is `State == RUNNING` :) Note that although `taskManager.hasActiveRunningTasks()` returns true, we may still not process any data (i.e. `totalProcessed` == 0 and we break the loop immediately).
But with the new condition, we will always execute `if (maybePunctuate() || maybeCommit())` anyways, so we only need to do `maybeUpdate` followed by a `maybeCommit` again. [ Full content available at: https://github.com/apache/kafka/pull/5428 ] This message was relayed via gitbox.apache.org for [email protected]
