From 94a03d178a3e1183a20b255d8cf5e8916550e548 Mon Sep 17 00:00:00 2001 From: Dream95 Date: Thu, 7 May 2026 19:53:42 +0800 Subject: [PATCH] [fix][broker] include segment descriptor in underlying topic name Signed-off-by: Dream95 --- .../broker/service/scalable/ScalableTopicController.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/scalable/ScalableTopicController.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/scalable/ScalableTopicController.java index 3bd562a48e100..db89dd3218467 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/scalable/ScalableTopicController.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/scalable/ScalableTopicController.java @@ -1106,7 +1106,8 @@ private String toSegmentUnderlyingPersistentName(SegmentInfo segment) { topicName, segment.hashRange(), segment.segmentId()); return "persistent://" + segmentTopicName.getTenant() + "/" + segmentTopicName.getNamespacePortion() + "/" - + segmentTopicName.getLocalName(); + + segmentTopicName.getLocalName() + "/" + + segmentTopicName.getSegmentDescriptor(); } private CompletableFuture terminateSegmentTopic(String segmentTopicName) {