m1a2st commented on code in PR #17117:
URL: https://github.com/apache/kafka/pull/17117#discussion_r1750247895
##########
tools/src/test/java/org/apache/kafka/tools/consumer/group/DescribeConsumerGroupTest.java:
##########
@@ -987,6 +987,7 @@ private Map<String, Object> composeConfigs(String groupId,
String groupProtocol,
configs.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
StringDeserializer.class.getName());
configs.put(ConsumerConfig.GROUP_PROTOCOL_CONFIG, groupProtocol);
configs.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG,
RangeAssignor.class.getName());
+ configs.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "1000");
Review Comment:
> Pardon me, not sure why we need to add this config
The document write that
> A new config, group.initial.rebalance.delay.ms, was introduced. This
config specifies the time, in milliseconds, that the GroupCoordinator will
delay the initial consumer rebalance. The rebalance will be further delayed by
the value of group.initial.rebalance.delay.ms as new members join the group, up
to a maximum of max.poll.interval.ms. The default value for this is 3 seconds.
During development and testing it might be desirable to set this to 0 in order
to not delay test execution time.
This config will speed up in the test
--
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
