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