We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bb619ab commit 5875f6eCopy full SHA for 5875f6e
1 file changed
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala
@@ -233,7 +233,7 @@ class DynamicBrokerConfigTest {
233
assertEquals(7, config.remoteLogManagerConfig.remoteLogManagerExpirationThreadPoolSize())
234
verify(remoteLogManager).resizeExpirationThreadPool(7)
235
236
- // When copier and expiration thread pools are set with the default value of -1, then it defaults to the remoteLogManagerThreadPoolSize
+ // When copier and expiration thread pools are set to -1 dynamically, then it defaults to the remoteLogManagerThreadPoolSize
237
props.put(RemoteLogManagerConfig.REMOTE_LOG_MANAGER_COPIER_THREAD_POOL_SIZE_PROP, "-1")
238
config.dynamicConfig.validate(props, perBrokerConfig = true)
239
config.dynamicConfig.updateDefaultConfig(props)
0 commit comments