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


Reply via email to