lkokhreidze commented on a change in pull request #11837: URL: https://github.com/apache/kafka/pull/11837#discussion_r827305741
########## File path: streams/src/test/java/org/apache/kafka/streams/integration/RackAwarenessIntegrationTest.java ########## @@ -108,55 +117,122 @@ public void cleanup() throws IOException { kafkaStreamsInstances.clear(); } + @Test + public void shouldThrowConfigExceptionWhenRackAwareAssignmentTagsExceedTheLimit() { Review comment: Was able to push up to a two hundred stateful tasks and even that was already slow. After 500, test was getting flaky on my computer and sometimes it was just failing due to timeouts. Feels like these kind of test is too heavy for a local integration tests. Any other way we could do it? Or any pointers to any of the existing integration tests that do the similar thing? Anyway, I've pushed the changes. I also found one bug in the `ClientTagAwareStandbyTaskAssignor` which is now fixed. -- 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