-
Notifications
You must be signed in to change notification settings - Fork 12k
Closed
Labels
Description
The example code shows how to use DefaultLitePullConsumer to pull data from rocketmq:
rocketmq/example/src/main/java/org/apache/rocketmq/example/simple/LitePullConsumerSubscribe.java
Line 35 in 8ef01a6
| List<MessageExt> messageExts = litePullConsumer.poll(); |
But i noticed that unlike the push mode( return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;), there is no code to reply an ack to the rocketmq for the pull consumer. So the question is : To ensure the data are correctly pulled, what should i do to manually reply an ack to the rockemq when using DefaultLitePullConsumer?
thanks~
Reactions are currently unavailable