[GitHub] [kafka] ableegoldman commented on a change in pull request #9688: KAFKA-10017: fix flaky EOS-beta upgrade test

ableegoldman commented on a change in pull request #9688: URL: https://github.com/apache/kafka/pull/9688#discussion_r538759641 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java ## @@ -792,24 +790,35 @@ public void

[GitHub] [kafka] ableegoldman commented on a change in pull request #9688: KAFKA-10017: fix flaky EOS-beta upgrade test

ableegoldman commented on a change in pull request #9688: URL: https://github.com/apache/kafka/pull/9688#discussion_r538757741 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java ## @@ -540,18 +535,18 @@ public void

[GitHub] [kafka] ableegoldman commented on a change in pull request #9688: KAFKA-10017: fix flaky EOS-beta upgrade test

ableegoldman commented on a change in pull request #9688: URL: https://github.com/apache/kafka/pull/9688#discussion_r536406055 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java ## @@ -916,11 +917,12 @@ public void

[GitHub] [kafka] ableegoldman commented on a change in pull request #9688: KAFKA-10017: fix flaky EOS-beta upgrade test

ableegoldman commented on a change in pull request #9688: URL: https://github.com/apache/kafka/pull/9688#discussion_r536321595 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java ## @@ -916,11 +917,12 @@ public void