Fix test

Signed-off-by: Zixuan Liu <[email protected]>

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicTest.java

@@ -1742,6 +1742,7 @@ public CompletableFuture<org.apache.pulsar.client.api.Producer> createAsync() {
                                 brokerService.pulsar().getPulsarResources().getClusterResources()
                                         .getCluster(remoteCluster))));
         replicatorMap.put(remoteReplicatorName, replicator);
+        String cursorName = PersistentReplicator.getReplicatorName(topic.getReplicatorPrefix(), remoteReplicatorName);
 
         // step-1 remove replicator : it will disconnect the producer but it will wait for callback to be completed
         Method removeMethod = PersistentTopic.class.getDeclaredMethod("removeReplicator", String.class);
@@ -1757,7 +1758,7 @@ public CompletableFuture<org.apache.pulsar.client.api.Producer> createAsync() {
 
         // step-3 : complete the callback to remove replicator from the list
         ArgumentCaptor<DeleteCursorCallback> captor = ArgumentCaptor.forClass(DeleteCursorCallback.class);
-        Mockito.verify(ledgerMock).asyncDeleteCursor(any(), captor.capture(), any());
+        Mockito.verify(ledgerMock).asyncDeleteCursor(eq(cursorName), captor.capture(), any());
         DeleteCursorCallback callback = captor.getValue();
         callback.deleteCursorComplete(null);
     }