Skip to content

Commit 18e4608

Browse files
MINOR: remove unused DelayedElectLeader (#19490)
The `DelayedElectLeader` is only used in `TestReplicaManager`, but there is no reference in it, so we can safely remove it. Reviewers: Chia-Ping Tsai <[email protected]>
1 parent 4b2a310 commit 18e4608

File tree

2 files changed

+1
-89
lines changed

2 files changed

+1
-89
lines changed

Diff for: core/src/main/scala/kafka/server/DelayedElectLeader.scala

-85
This file was deleted.

Diff for: core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala

+1-4
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,6 @@ object AbstractCoordinatorConcurrencyTest {
172172
val producePurgatory: DelayedOperationPurgatory[DelayedProduce],
173173
val delayedFetchPurgatoryParam: DelayedOperationPurgatory[DelayedFetch],
174174
val delayedDeleteRecordsPurgatoryParam: DelayedOperationPurgatory[DelayedDeleteRecords],
175-
val delayedElectLeaderPurgatoryParam: DelayedOperationPurgatory[DelayedElectLeader],
176175
val delayedRemoteFetchPurgatoryParam: DelayedOperationPurgatory[DelayedRemoteFetch],
177176
val delayedRemoteListOffsetsPurgatoryParam: DelayedOperationPurgatory[DelayedRemoteListOffsets])
178177
extends ReplicaManager(
@@ -290,10 +289,8 @@ object AbstractCoordinatorConcurrencyTest {
290289
"Fetch", timer, 0, 1000, false, true)
291290
val mockDeleteRecordsPurgatory = new DelayedOperationPurgatory[DelayedDeleteRecords](
292291
"DeleteRecords", timer, 0, 1000, false, true)
293-
val mockElectLeaderPurgatory = new DelayedOperationPurgatory[DelayedElectLeader](
294-
"ElectLeader", timer, 0, 1000, false, true)
295292
new TestReplicaManager(config, time, scheduler, logManager, quotaManagers, watchKeys, producePurgatory,
296-
mockFetchPurgatory, mockDeleteRecordsPurgatory, mockElectLeaderPurgatory, mockRemoteFetchPurgatory,
293+
mockFetchPurgatory, mockDeleteRecordsPurgatory, mockRemoteFetchPurgatory,
297294
mockRemoteListOffsetsPurgatory)
298295
}
299296
}

0 commit comments

Comments
 (0)