andrewgrantcflt commented on code in PR #23245:
URL: https://github.com/apache/kafka/pull/23245#discussion_r3854520374
##########
raft/src/main/java/org/apache/kafka/raft/KRaftConfigs.java:
##########
@@ -69,6 +69,12 @@ public class KRaftConfigs {
public static final long
CONTROLLER_PERFORMANCE_ALWAYS_LOG_THRESHOLD_MS_DEFAULT = 2000;
public static final String
CONTROLLER_PERFORMANCE_ALWAYS_LOG_THRESHOLD_MS_DOC = "We will log an error
message about controller events that take longer than this threshold.";
+ public static final String CONTROLLER_MAX_PARTITIONS_PER_BATCH_CONFIG =
"controller.max.partitions.per.batch";
+ public static final int CONTROLLER_MAX_PARTITIONS_PER_BATCH_DEFAULT =
10_000;
+ public static final String CONTROLLER_MAX_PARTITIONS_PER_BATCH_DOC = "The
maximum number of partitions that the " +
+ "active controller will allow to be created by a single
CreateTopics request. This limit protects the " +
Review Comment:
Agreed. Updated, especially as now the config is used in other places where
we had the 10,000 limit for the max number of metadata records we can add to a
single batch.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
