From 7b69e995f2c034b9a06c644b4bd7f9864d06ded5 Mon Sep 17 00:00:00 2001
From: Matteo Merli <mmerli@apache.org>
Date: Mon, 7 Oct 2019 16:21:53 -0700
Subject: [PATCH] Do not use timed receive in
 BrokerClientIntegrationTest.testUnsupportedBatchMessageConsumer

---
 .../apache/pulsar/client/impl/BrokerClientIntegrationTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
index a1622e1fd5317..15357d318c8d6 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
@@ -384,7 +384,7 @@ public void testUnsupportedBatchMessageConsumer(SubscriptionType subType) throws
 
         messageSet.clear();
         for (int i = 0; i < numMessagesPerBatch; i++) {
-            msg = consumer2.receive(1, TimeUnit.SECONDS);
+            msg = consumer2.receive();
             String receivedMessage = new String(msg.getData());
             log.debug("Received message: [{}]", receivedMessage);
             String expectedMessage = "my-batch-message-" + i;