fix(core): fix leader fast ABA reassign cause epoch outdated (#1187)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Apr 28, 2024 · 666cae2 · 666cae2
1 parent 32c101b
commit 666cae2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -2657,6 +2657,7 @@ class ReplicaManager(val config: KafkaConfig,
           throw new IllegalStateException(s"Topic $tp exists, but its ID is " +
             s"${partition.topicId.get}, not $topicId as expected")
         }
+        createHook.accept(partition)
         Some(partition, false)
 
       case HostedPartition.None =>