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) {