This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 847ff8f MINOR: Use `forEach` and `ifPresent` to simplify Scala code (#8642) add fe2742e KAFKA-9972: Only commit tasks with valid states (#8632) No new revisions were added by this update. Summary of changes: .../streams/processor/internals/StreamThread.java | 9 ++- .../streams/processor/internals/TaskManager.java | 9 +-- .../processor/internals/StreamThreadTest.java | 66 +++++++++++++++++++++- 3 files changed, 77 insertions(+), 7 deletions(-)