dajac commented on a change in pull request #9573:
URL: https://github.com/apache/kafka/pull/9573#discussion_r519620665
##########
File path: core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala
##########
@@ -62,14 +64,16 @@ class IsrExpirationTest {
EasyMock.replay(logManager)
alterIsrManager = TestUtils.createAlterIsrManager()
+ quotaManager = QuotaFactory.instantiate(configs.head, metrics, time, "")
replicaManager = new ReplicaManager(configs.head, metrics, time, null,
null, logManager, new AtomicBoolean(false),
- QuotaFactory.instantiate(configs.head, metrics, time, ""), new
BrokerTopicStats, new MetadataCache(configs.head.brokerId),
+ quotaManager, new BrokerTopicStats, new
MetadataCache(configs.head.brokerId),
new LogDirFailureChannel(configs.head.logDirs.size), alterIsrManager)
}
@After
def tearDown(): Unit = {
replicaManager.shutdown(false)
+ quotaManager.shutdown()
Review comment:
nit: We should check that `quotaManager` is not null. We can also do it
for `replicaManager` above.
##########
File path: core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
##########
@@ -1506,7 +1508,7 @@ class ReplicaManagerTest {
purgatoryName = "ElectLeader", timer, reaperEnabled = false)
// Mock network client to show leader offset of 5
- val quota = QuotaFactory.instantiate(config, metrics, time, "")
+ val quota = quotaManager
Review comment:
nit: Could we get rid of `quota`?
##########
File path: core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
##########
@@ -79,22 +81,24 @@ class ReplicaManagerTest {
EasyMock.expect(kafkaZkClient.getEntityConfigs(EasyMock.anyString(),
EasyMock.anyString())).andReturn(new Properties()).anyTimes()
EasyMock.replay(kafkaZkClient)
+ val props = TestUtils.createBrokerConfig(1, TestUtils.MockZkConnect)
+ config = KafkaConfig.fromProps(props)
alterIsrManager = EasyMock.createMock(classOf[AlterIsrManager])
+ quotaManager = QuotaFactory.instantiate(config, metrics, time, "")
}
@After
def tearDown(): Unit = {
TestUtils.clearYammerMetrics()
+ quotaManager.shutdown()
Review comment:
Should we check that `quotaManager` is not null?
##########
File path:
core/src/test/scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala
##########
@@ -112,4 +120,11 @@ class OffsetsForLeaderEpochTest {
//Then
assertEquals(new EpochEndOffset(Errors.UNKNOWN_TOPIC_OR_PARTITION,
UNDEFINED_EPOCH, UNDEFINED_EPOCH_OFFSET), response(tp))
}
+
+ @After
+ def tearDown(): Unit = {
+ replicaManager.shutdown(checkpointHW = false)
+ quotaManager.shutdown()
Review comment:
We should check non null in both cases.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
