lordcheng10 commented on code in PR #18107:
URL: https://github.com/apache/pulsar/pull/18107#discussion_r1000063396
##########
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java:
##########
@@ -378,6 +378,17 @@
*/
ConsumerBuilder<T> acknowledgmentGroupTime(long delay, TimeUnit unit);
+ /**
+ * Group the consumer acknowledgments for size.
+ *
+ * <p>By default, the consumer uses 1000 messages to send out the
acknowledgments to the broker.
+ *
+ * @param messageNum
+ *
+ * @return the consumer builder instance
+ */
+ ConsumerBuilder<T> acknowledgmentGroupSize(int messageNum);
Review Comment:
OK
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
