From 1dc1a6f499baa99b920e876a8449af9994af321d Mon Sep 17 00:00:00 2001
From: Robin Han <hanxvdovehx@gmail.com>
Date: Sun, 28 Apr 2024 15:38:09 +0800
Subject: [PATCH] fix(core): fix leader fast ABA reassign cause epoch outdated

Signed-off-by: Robin Han <hanxvdovehx@gmail.com>
---
 core/src/main/scala/kafka/server/ReplicaManager.scala | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
index 4684bc47d0..bbbeeb5c38 100644
--- 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 =>