diff --git a/pulsar-client-tools-test/src/test/java/org/apache/pulsar/client/cli/PulsarClientToolTest.java b/pulsar-client-tools-test/src/test/java/org/apache/pulsar/client/cli/PulsarClientToolTest.java
index e9dc0e53627ba..d56308911ddf4 100644
--- a/pulsar-client-tools-test/src/test/java/org/apache/pulsar/client/cli/PulsarClientToolTest.java
+++ b/pulsar-client-tools-test/src/test/java/org/apache/pulsar/client/cli/PulsarClientToolTest.java
@@ -183,13 +183,12 @@ public void testDurableSubscribe() throws Exception {
         String[] args = {"produce", "--messages", "Have a nice day", "-n", Integer.toString(numberOfMessages), "-r",
                 "20", "-p", "key1=value1", "-p", "key2=value2", "-k", "partition_key", topicName};
         Assert.assertEquals(pulsarClientToolProducer.run(args), 0);
-        Assert.assertFalse(future.isCompletedExceptionally());
-        future.get();
-        //wait for close
-        Awaitility.waitAtMost(Duration.ofDays(2000));
-        List<String> subscriptions = admin.topics().getSubscriptions(topicName);
-        Assert.assertNotNull(subscriptions);
-        Assert.assertEquals(subscriptions.size(), 1);
+
+        try {
+            future.get(10, TimeUnit.SECONDS);
+        } catch (Exception e) {
+            Assert.fail("consumer was unable to receive messages", e);
+        }
     }
 
     @Test(timeOut = 20000)
@@ -230,7 +229,6 @@ public void testEncryption() throws Exception {
 
         try {
             future.get(10, TimeUnit.SECONDS);
-            Assert.assertFalse(future.isCompletedExceptionally());
         } catch (Exception e) {
             Assert.fail("consumer was unable to decrypt messages", e);
         }