File tree Expand file tree Collapse file tree
core/src/test/scala/unit/kafka/server Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -251,16 +251,24 @@ class DynamicBrokerConfigTest {
251251 config.dynamicConfig.updateDefaultConfig(props)
252252 assertEquals(6 , config.remoteLogManagerConfig.remoteLogReaderThreads())
253253 verify(remoteLogManager).resizeReaderThreadPool(6 )
254+ props.clear()
254255
255256 // Test dynamic update with invalid values
256257 props.put(RemoteLogManagerConfig .REMOTE_LOG_MANAGER_COPIER_THREAD_POOL_SIZE_PROP , " 0" )
257258 assertThrows(classOf [ConfigException ], () => config.dynamicConfig.validate(props, perBrokerConfig = true ))
259+ props.clear()
260+
258261 props.put(RemoteLogManagerConfig .REMOTE_LOG_MANAGER_EXPIRATION_THREAD_POOL_SIZE_PROP , " -2" )
259262 assertThrows(classOf [ConfigException ], () => config.dynamicConfig.validate(props, perBrokerConfig = false ))
263+ props.clear()
264+
260265 props.put(RemoteLogManagerConfig .REMOTE_LOG_READER_THREADS_PROP , " 2" )
261266 assertThrows(classOf [ConfigException ], () => config.dynamicConfig.validate(props, perBrokerConfig = false ))
267+ props.clear()
268+
262269 props.put(RemoteLogManagerConfig .REMOTE_LOG_READER_THREADS_PROP , " -1" )
263270 assertThrows(classOf [ConfigException ], () => config.dynamicConfig.validate(props, perBrokerConfig = true ))
271+ props.clear()
264272 verifyNoMoreInteractions(remoteLogManager)
265273 }
266274
You can’t perform that action at this time.
0 commit comments