[GitHub] [kafka] chia7712 commented on a change in pull request #8913: KAFKA-10191 fix flaky StreamsOptimizedTest

chia7712 commented on a change in pull request #8913: URL: https://github.com/apache/kafka/pull/8913#discussion_r448711625 ## File path: core/src/main/scala/kafka/tools/StreamsResetter.java ## @@ -168,7 +168,7 @@ public int run(final String[] args,

[GitHub] [kafka] chia7712 commented on a change in pull request #8913: KAFKA-10191 fix flaky StreamsOptimizedTest

chia7712 commented on a change in pull request #8913: URL: https://github.com/apache/kafka/pull/8913#discussion_r447488640 ## File path: tests/kafkatest/services/streams.py ## @@ -445,6 +449,40 @@ def __init__(self, test_context, kafka, configs):

[GitHub] [kafka] chia7712 commented on a change in pull request #8913: KAFKA-10191 fix flaky StreamsOptimizedTest - call KafkaStreams#cleanU…

chia7712 commented on a change in pull request #8913: URL: https://github.com/apache/kafka/pull/8913#discussion_r444374011 ## File path: streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java ## @@ -130,6 +130,8 @@ public static void main(final

[GitHub] [kafka] chia7712 commented on a change in pull request #8913: KAFKA-10191 fix flaky StreamsOptimizedTest - call KafkaStreams#cleanU…

chia7712 commented on a change in pull request #8913: URL: https://github.com/apache/kafka/pull/8913#discussion_r444373556 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java ## @@ -303,7 +303,8 @@ public void