Fix cherry-pick issue

Author: nikhil-ctds

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

@@ -1664,41 +1664,6 @@ public void testDynamicConfigurationsForceDeleteTenantAllowed() throws Exception
         });
     }
 
-    @Test
-    public void testIsSystemTopicAllowAutoTopicCreationAsync() throws Exception {
-        BrokerService brokerService = pulsar.getBrokerService();
-        assertFalse(brokerService.isAllowAutoTopicCreationAsync(
-                ServiceUnitStateChannelImpl.TOPIC).get());
-        assertTrue(brokerService.isAllowAutoTopicCreationAsync(
-                "persistent://pulsar/system/my-system-topic").get());
-    }
-
-    @Test
-    public void testDuplicateAcknowledgement() throws Exception {
-        final String ns = "prop/ns-test";
-
-        admin.namespaces().createNamespace(ns, 2);
-        final String topicName = "persistent://prop/ns-test/duplicated-acknowledgement-test";
-        @Cleanup
-        Producer<byte[]> producer = pulsarClient.newProducer()
-                .topic(topicName)
-                .create();
-        @Cleanup
-        Consumer<byte[]> consumer1 = pulsarClient.newConsumer()
-                .topic(topicName)
-                .subscriptionName("sub-1")
-                .acknowledgmentGroupTime(0, TimeUnit.SECONDS)
-                .subscriptionType(SubscriptionType.Shared)
-                .isAckReceiptEnabled(true)
-                .subscribe();
-        producer.send("1".getBytes(StandardCharsets.UTF_8));
-        Message<byte[]> message = consumer1.receive();
-        consumer1.acknowledge(message);
-        consumer1.acknowledge(message);
-        assertEquals(admin.topics().getStats(topicName).getSubscriptions()
-                .get("sub-1").getUnackedMessages(), 0);
-    }
-
     @Test
     public void testBlockedConsumerOnUnackedMsgs() throws Exception {
         final String ns = "prop/ns-test";
@@ -1740,31 +1705,6 @@ public void testBlockedConsumerOnUnackedMsgs() throws Exception {
         assertFalse(subscriptionStats.getConsumers().get(0).isBlockedConsumerOnUnackedMsgs());
     }
 
-    @Test
-    public void testUnsubscribeNonDurableSub() throws Exception {
-        final String ns = "prop/ns-test";
-        final String topic = ns + "/testUnsubscribeNonDurableSub";
-
-        admin.namespaces().createNamespace(ns, 2);
-        admin.topics().createPartitionedTopic(String.format("persistent://%s", topic), 1);
-
-        pulsarClient.newProducer(Schema.STRING).topic(topic).create().close();
-        @Cleanup
-        Consumer<String> consumer = pulsarClient
-                .newConsumer(Schema.STRING)
-                .topic(topic)
-                .subscriptionMode(SubscriptionMode.NonDurable)
-                .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
-                .subscriptionName("sub1")
-                .subscriptionType(SubscriptionType.Shared)
-                .subscribe();
-        try {
-            consumer.unsubscribe();
-        } catch (Exception ex) {
-            fail("Unsubscribe failed");
-        }
-    }
-
     // this test is disabled since it is flaky
     @Test(enabled = false)
     public void testMetricsPersistentTopicLoadFails() throws Exception {