Open jabrena opened 4 years ago
Consumer consumer = client.newConsumer() .topic("my-topic") .subscriptionName("my-subscription") .batchReceivePolicy(BatchReceivePolicy.builder() .maxNumMessages(100) .maxNumBytes(1024 * 1024) .timeout(200, TimeUnit.MILLISECONDS) .build()) .subscribe();