[fix][test] Remove obsolete tests

Author: nodece

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

@@ -2082,106 +2082,4 @@ public void testReplicatorWhenPartitionCountsDiffer() throws Exception {
             assertEquals(receive.getValue(), "msg-p2-1");
         }
     }
-
-    // https://github.com/apache/pulsar/pull/24118 has denied a client to access a non-partitioned topic that end with
-    // "-partition-{num}", but it is not cherry-picked to previous branches.
-    // To guarantee compatibility with previous releases, the following tests should work for the releases that is
-    // earlier than "4.1.0".
-    // When cherry-picking the PR into previous branches, the following tests should be enabled.
-    // I will push a seperate PR to remove these tests.
-//    @Test
-//    public void testReplicatorWithSpecialNonPartitionedTopic() throws Exception {
-//        if (usingGlobalZK) {
-//            // This test case is not applicable when using global ZK, because the namespace policies
-//            // are shared among clusters.
-//            return;
-//        }
-//
-//        String tp = BrokerTestUtil.newUniqueName("persistent://" + replicatedNamespace + "/tp") + "-partition-4";
-//        String mlName = TopicName.get(tp).getPersistenceNamingEncoding();
-//        pulsar1.getDefaultManagedLedgerFactory().open(mlName);
-//        pulsar2.getDefaultManagedLedgerFactory().open(mlName);
-//        Producer<String> p1 = client1.newProducer(Schema.STRING).topic(tp).create();
-//        Consumer<String> c2 = client2.newConsumer(Schema.STRING).topic(tp).subscriptionName("test-sub")
-//                .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest).subscribe();
-//
-//        waitReplicatorStarted(tp);
-//        p1.send("abc");
-//        Message<String> msg = c2.receive(2, TimeUnit.SECONDS);
-//        assertNotNull(msg);
-//        assertEquals(msg.getValue(), "abc");
-//
-//        // cleanup
-//        p1.close();
-//        c2.close();
-//    }
-//
-//    @Test
-//    public void testFailureReplicatorWithSpecialNonPartitionedTopic() throws Exception {
-//        if (usingGlobalZK) {
-//            // This test case is not applicable when using global ZK, because the namespace policies
-//            // are shared among clusters.
-//            return;
-//        }
-//
-//        String tp = BrokerTestUtil.newUniqueName("persistent://" + replicatedNamespace + "/tp") + "-partition-0";
-//        String mlName = TopicName.get(tp).getPersistenceNamingEncoding();
-//        pulsar2.getDefaultManagedLedgerFactory().open(mlName);
-//        Thread.sleep(3000);
-//        admin1.topics().createPartitionedTopic(TopicName.get(tp).getPartitionedTopicName(), 1);
-//        Producer<String> p1 = client1.newProducer(Schema.STRING).topic(tp).create();
-//        Producer<String> p2 = client2.newProducer(Schema.STRING).topic(tp).create();
-//        p1.send("123");
-//        p2.send("321");
-//        Thread.sleep(3000);
-//
-//        Awaitility.await().untilAsserted(() -> {
-//            PersistentTopic persistentTopic = (PersistentTopic) broker1
-//                    .getTopic(TopicName.get(tp).getPartition(0).toString(), false).join().get();
-//            assertTrue(persistentTopic.getReplicators().isEmpty()
-//                    || !persistentTopic.getReplicators().get(cluster2).isConnected());
-//        });
-//
-//        // cleanup
-//        p1.close();
-//        p2.close();
-//        cleanupTopics(() -> {
-//            admin1.topics().deletePartitionedTopic(TopicName.get(tp).getPartitionedTopicName());
-//            admin2.topics().delete(tp);
-//        });
-//    }
-//
-//    @Test
-//    public void testFailureReplicatorWithSpecialNonPartitionedTopic2() throws Exception {
-//        if (usingGlobalZK) {
-//            // This test case is not applicable when using global ZK, because the namespace policies
-//            // are shared among clusters.
-//            return;
-//        }
-//
-//        String tp = BrokerTestUtil.newUniqueName("persistent://" + replicatedNamespace + "/tp") + "-partition-0";
-//        String mlName = TopicName.get(tp).getPersistenceNamingEncoding();
-//        pulsar1.getDefaultManagedLedgerFactory().open(mlName);
-//        Thread.sleep(3000);
-//        admin2.topics().createPartitionedTopic(TopicName.get(tp).getPartitionedTopicName(), 1);
-//        Producer<String> p1 = client1.newProducer(Schema.STRING).topic(tp).create();
-//        Producer<String> p2 = client2.newProducer(Schema.STRING).topic(tp).create();
-//        p1.send("123");
-//        p2.send("321");
-//        Thread.sleep(3000);
-//
-//        Awaitility.await().untilAsserted(() -> {
-//            PersistentTopic persistentTopic = (PersistentTopic) broker1.getTopic(tp, false).join().get();
-//            assertTrue(persistentTopic.getReplicators().isEmpty()
-//                    || !persistentTopic.getReplicators().get(cluster2).isConnected());
-//        });
-//
-//        // cleanup
-//        p1.close();
-//        p2.close();
-//        cleanupTopics(() -> {
-//            admin1.topics().delete(tp);
-//            admin2.topics().deletePartitionedTopic(TopicName.get(tp).getPartitionedTopicName());
-//        });
-//    }
 }