Open jabrena opened 4 years ago
Messages<T> batchReceive() throws PulsarClientException Batch receiving messages. This calls blocks until has enough messages or wait timeout, more details to see BatchReceivePolicy.