vvcephei commented on a change in pull request #11581:
URL: https://github.com/apache/kafka/pull/11581#discussion_r766221104
##########
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##########
@@ -1764,20 +1764,18 @@ protected void processStreamThread(final
Consumer<StreamThread> consumer) {
);
}
final StateQueryResult<R> result = new StateQueryResult<>();
+ final Set<Integer> handledPartitions = new HashSet<>();
Review comment:
Oh, sorry about that. That was an artifact from a recent refactor. But
now that I'm looking at it, I realize we don't need a separate set for tracking
this, since we can use the result's partition set itself.
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
