guozhangwang commented on code in PR #12397:
URL: https://github.com/apache/kafka/pull/12397#discussion_r927019010
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -262,51 +294,30 @@ Collection tasks(final Collection taskIds) {
// TO
guozhangwang commented on code in PR #12397:
URL: https://github.com/apache/kafka/pull/12397#discussion_r925945110
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java:
##
@@ -216,8 +216,9 @@ long partitionTimestamp(final TopicPartition parti
guozhangwang commented on code in PR #12397:
URL: https://github.com/apache/kafka/pull/12397#discussion_r925892759
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java:
##
@@ -234,6 +236,43 @@ public void closeCleanAndRecycleState() {
l
guozhangwang commented on code in PR #12397:
URL: https://github.com/apache/kafka/pull/12397#discussion_r925882848
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -34,29 +33,40 @@
import java.util.TreeMap;
import java.util.stream.Collect
guozhangwang commented on code in PR #12397:
URL: https://github.com/apache/kafka/pull/12397#discussion_r925881686
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java:
##
@@ -55,25 +57,28 @@ public abstract class AbstractTask implements Task {
guozhangwang commented on code in PR #12397:
URL: https://github.com/apache/kafka/pull/12397#discussion_r925880702
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -1307,9 +1307,9 @@ public Set characteristics() {
}
@SafeVarargs
-public st
guozhangwang commented on code in PR #12397:
URL: https://github.com/apache/kafka/pull/12397#discussion_r917191699
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -34,29 +33,40 @@
import java.util.TreeMap;
import java.util.stream.Collect
