apourchet commented on code in PR #16201:
URL: https://github.com/apache/kafka/pull/16201#discussion_r1629804457
##########
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java:
##########
@@ -190,11 +197,35 @@ private void completeLargeAssignment(final int
numPartitions,
configMap.put(InternalConfig.INTERNAL_TASK_ASSIGNOR_CLASS,
taskAssignor.getName());
configMap.put(StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG, numStandbys);
- final MockInternalTopicManager mockInternalTopicManager = new
MockInternalTopicManager(
+ configMap.put(StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG,
+ StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_NONE);
Review Comment:
No they both take way too long for some of the scale tests.
--
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
