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

KAFKA-18486 Remove ReplicaManager#becomeLeaderOrFollower from `testReplicaAlterLogDirs` (#19922) 

Use `applyDelta` replace `becomeLeaderOrFollower`

Reviewers: Ken Huang <s7133700@gmail.com>, Chia-Ping Tsai
<chia7712@gmail.com>
This commit is contained in:
Nick Guo 2025-06-09 03:00:00 +08:00 committed by GitHub
parent 8fd0d33670
commit e23c8cea07
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala
View File

@ -5864,6 +5864,7 @@ class ReplicaManagerTest {
@Test
def testReplicaAlterLogDirs(): Unit = {
val localId = 0
val tp = new TopicPartition(topic, 0)
val mockReplicaAlterLogDirsManager = mock(classOf[ReplicaAlterLogDirsManager])
@ -5880,13 +5881,9 @@ class ReplicaManagerTest {
topicId = None
)
val leaderAndIsrRequest = makeLeaderAndIsrRequest(
topicId = topicId,
topicPartition = tp,
replicas = Seq(0, 1),
leaderAndIsr = new LeaderAndIsr(0, List(0, 1).map(Int.box).asJava),
)
replicaManager.becomeLeaderOrFollower(0, leaderAndIsrRequest, (_, _) => ())
val leaderDelta = topicsCreateDelta(localId, isStartIdLeader = true, partitions = List(0, 1), List.empty, topic, topicIds(topic))
val leaderImage = imageFromTopics(leaderDelta.apply())
replicaManager.applyDelta(leaderDelta, leaderImage)
// Move the replica to the second log directory.
val partition = replicaManager.getPartitionOrException(tp)