From 666cae22fca0895661be2700a09dcfe1d4ffb9f6 Mon Sep 17 00:00:00 2001
From: "Xu Han@AutoMQ" <hanxvdovehx@gmail.com>
Date: Sun, 28 Apr 2024 15:58:20 +0800
Subject: [PATCH] fix(core): fix leader fast ABA reassign cause epoch outdated
 (#1187)

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 =>