You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2020/06/09 15:56:09 UTC
[GitHub] [pulsar] BewareMyPower opened a new pull request #7216: [C++] Wait for all seek operations completed
BewareMyPower opened a new pull request #7216:
URL: https://github.com/apache/pulsar/pull/7216
### Motivation
When a partitioned consumer calls `seek`, it waits for only one partition's seek operation completed because each internal consumer calls `callback(result)` to complete the same `Promise`.
### Modifications
- Add a `MultiResultCallback` implementation, the callback completes only if all N events completes successfully or one of N events failed.
- Use `MultiResultCallback` to wrap `callback` from `PartitionedConsumerImpl::seekAsync`.
----------------------------------------------------------------
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
[GitHub] [pulsar] BewareMyPower commented on pull request #7216: [C++] Wait for all seek operations completed
Posted by GitBox <gi...@apache.org>.
BewareMyPower commented on pull request #7216:
URL: https://github.com/apache/pulsar/pull/7216#issuecomment-641123862
----------------------------------------------------------------
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
[GitHub] [pulsar] jiazhai merged pull request #7216: [C++] Wait for all seek operations completed
Posted by GitBox <gi...@apache.org>.
jiazhai merged pull request #7216:
URL: https://github.com/apache/pulsar/pull/7216
----------------------------------------------------------------
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