File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
core/src/main/scala/kafka/cluster Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -563,7 +563,7 @@ class Partition(val topicPartition: TopicPartition,
563
563
564
564
private def clear (): Unit = {
565
565
remoteReplicasMap.clear()
566
- assignmentState = new SimpleAssignmentState (util. List .of() )
566
+ assignmentState = new SimpleAssignmentState (Seq .empty.asJava )
567
567
log = None
568
568
futureLog = None
569
569
partitionState = new CommittedPartitionState (util.Set .of(), LeaderRecoveryState .RECOVERED )
@@ -1799,7 +1799,7 @@ class Partition(val topicPartition: TopicPartition,
1799
1799
// 2) leaderAndIsr.partitionEpoch == partitionEpoch: No update was performed since proposed and actual state are the same.
1800
1800
// In both cases, we want to move from Pending to Committed state to ensure new updates are processed.
1801
1801
1802
- partitionState = new CommittedPartitionState (util.Set .copyOf (leaderAndIsr.isr), leaderAndIsr.leaderRecoveryState)
1802
+ partitionState = new CommittedPartitionState (new util.HashSet (leaderAndIsr.isr), leaderAndIsr.leaderRecoveryState)
1803
1803
partitionEpoch = leaderAndIsr.partitionEpoch
1804
1804
info(s " ISR updated to ${partitionState.isr.asScala.mkString(" ," )} ${if (isUnderMinIsr) " (under-min-isr)" else " " } " +
1805
1805
s " and version updated to $partitionEpoch" )
You can’t perform that action at this time.
0 commit comments