root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

fix

This commit is contained in:
tony tang 2025-10-06 17:56:01 -05:00
parent c46ce30600
commit 509a0d2854
No known key found for this signature in database
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/test/scala/kafka/server/KafkaRequestHandlerTest.scala
View File

@ -774,6 +774,8 @@ class KafkaRequestHandlerTest {
assertEquals(2, brokerPool.threadPoolSize.get) assertEquals(2, brokerPool.threadPoolSize.get)
assertEquals(6, controllerPool.threadPoolSize.get) assertEquals(6, controllerPool.threadPoolSize.get)
assertEquals(8, KafkaRequestHandlerPool.aggregateThreads.get) assertEquals(8, KafkaRequestHandlerPool.aggregateThreads.get)
// Wait for removed threads to fully exit before shutdown to avoid deadlock.
Thread.sleep(1000) Thread.sleep(1000)
} finally { } finally {