diff --git a/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java b/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java
index 39c02b0c5a50..ca0c4809ca92 100644
--- a/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java
+++ b/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java
@@ -289,11 +289,9 @@ public void testReadWithMultipleTopics() throws Exception {
             .withConnectionConfiguration(
                 MqttIO.ConnectionConfiguration.createWithMultipleTopics(
                     "tcp://localhost:" + port, Arrays.asList(topic1, topic2)))
-            .withMaxNumRecords(15)
-            .withMaxReadTime(Duration.standardSeconds(5));
+            .withMaxNumRecords(10);
 
     final PCollection<MqttRecord> output = pipeline.apply(mqttReaderWithTopicArray);
-
     PAssert.that(output)
         .satisfies(
             iter -> {