You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/04/15 05:46:24 UTC
[GitHub] [rocketmq-client-cpp] he1016060110 opened a new issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
he1016060110 opened a new issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298
对于DefaultMQPushConsumer，代码里面写死了maxNum为32，但是一次消费32条，部分成功，部分失败了，我该怎么在callback里面返回哪些消息成功，哪些需要reconsume，因为默认status只有一个，也就是要么全成功，要么全失败。
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] ShannonDing closed issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
ShannonDing closed issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-614387802
@he1016060110 Call sendMessageBack by yourself, then return RECONSUME_LATER. But latest client not expose sendMessageBack in DefaultMQPushConsumer. Add it, and call DefaultMQPushConsumerImpl#sendMessageBack
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] ShannonDing commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
ShannonDing commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-613840149
once the RECONSUME_LATER return, all the messages in the vector will be sent back to the broker. you should do not change the message vectors.
and more, Issues are generally used for bug reports and feature requests, so if you have any questions about Apache RocketMQ, it is recommended to discuss it on the mailing list first, the mailing list [address](https://rocketmq.apache.org/about/contact). I will close the Issue first, but please feel free to reopen it if you have any other issues.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] he1016060110 commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
he1016060110 commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-613836370
我看到consumeMessage传的msg引用
ConsumeStatus consumeMessage(const std::vector<MQMessageExt>& msgs) = 0;
我应该可以把这个vector改了，然后传RECONSUME_LATER吧
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] ShannonDing commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
ShannonDing commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-615003971
IMO, It is not recommended to open this capability. In order to deal with simplicity and ensure the reliability and order as much as possible, the logic of sending back the broker is handled internally by the client and guarantees the success of the return. If this function is opened, it means that the failure to send back is uncontrollable, which increases the risk of message loss.
In addition, if you don't want to report errors in batches, you can directly reply to CONSUMER_SUCCESS and re-deliver the failed message as a new message to this topic through a new independent producer.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] he1016060110 commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
he1016060110 commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-614360297
> You can set consume batch size to 1 by DefaultMQPushConsumer::setConsumeMessageBatchMaxSize.
tried.the concurrency is so low.so i suggest that consumeMessage should contains two params,like solution below
consumeMessage(const std::vector& msgs, std::vecotr & batchStatus)
so that we can send message back according to the different status of every message of the batch.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] ifplusor edited a comment on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
ifplusor edited a comment on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-614387802
@he1016060110 Call sendMessageBack by yourself, then return CONSUME_SUCCESS. But latest client not expose sendMessageBack in DefaultMQPushConsumer. Add it, and call DefaultMQPushConsumerImpl#sendMessageBack
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-613849766
You can set consume batch size to 1 by DefaultMQPushConsumer::setConsumeMessageBatchMaxSize.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #298: DefaultMQPushConsumer callback里面如果部分成功如果处理
URL: https://github.com/apache/rocketmq-client-cpp/issues/298#issuecomment-614388143
@ShannonDing Can we expose sendMessageBack in DefaultMQPushConsumer?
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services