Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[feature][client-cpp] Support inclusive seek for cpp client #17209

Merged

Conversation

Demogorgon314
Copy link
Member

@Demogorgon314 Demogorgon314 commented Aug 22, 2022

Fixes #17186

Motivation

There are some cases in which it is useful to be able to include current
position of the message when reset of cursor was made.

Modifications

  • Support inclusive seek in c++ consumers.
  • Add a unit test to verify.

Documentation

Check the box below or label this PR directly.

Need to update docs?

  • doc-required
    (Your PR needs to update docs and you will update later)

  • doc-not-needed
    (Please explain why)

  • doc
    (Your PR contains doc changes)

  • doc-complete
    (Docs have been already added)

@Demogorgon314 Demogorgon314 added type/feature The PR added a new feature or issue requested a new feature component/client-c++ labels Aug 22, 2022
@Demogorgon314 Demogorgon314 self-assigned this Aug 22, 2022
@Demogorgon314 Demogorgon314 force-pushed the Demogorgon314/cpp-inclusive-seek branch 2 times, most recently from 32274c0 to 4af9b85 Compare August 25, 2022 07:17
@Demogorgon314
Copy link
Member Author

This feature is based on @BewareMyPower 's branch and added some missing parts. Thanks @BewareMyPower 's great work!

@Demogorgon314 Demogorgon314 marked this pull request as ready for review August 25, 2022 07:20
@Demogorgon314 Demogorgon314 force-pushed the Demogorgon314/cpp-inclusive-seek branch 2 times, most recently from b722e60 to 7aa0caa Compare August 27, 2022 09:26
@Demogorgon314 Demogorgon314 force-pushed the Demogorgon314/cpp-inclusive-seek branch from 7aa0caa to 55278a0 Compare August 30, 2022 01:31
@Demogorgon314 Demogorgon314 marked this pull request as draft August 30, 2022 03:19
@Demogorgon314 Demogorgon314 marked this pull request as ready for review August 30, 2022 08:19
@BewareMyPower
Copy link
Contributor

Could you resolve the conflicts?

@Demogorgon314 Demogorgon314 force-pushed the Demogorgon314/cpp-inclusive-seek branch from 6e92102 to 6b00973 Compare September 2, 2022 01:40
Copy link
Member

@shibd shibd left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Just left some small comments.

pulsar-client-cpp/lib/ConsumerImpl.cc Outdated Show resolved Hide resolved
pulsar-client-cpp/python/pulsar_test.py Show resolved Hide resolved
pulsar-client-cpp/lib/ConsumerImpl.h Outdated Show resolved Hide resolved
pulsar-client-cpp/lib/ConsumerImpl.cc Outdated Show resolved Hide resolved
pulsar-client-cpp/lib/ConsumerImpl.cc Outdated Show resolved Hide resolved
pulsar-client-cpp/lib/ConsumerImpl.h Outdated Show resolved Hide resolved
pulsar-client-cpp/lib/ConsumerImpl.cc Show resolved Hide resolved
pulsar-client-cpp/tests/ConsumerTest.cc Outdated Show resolved Hide resolved
@Demogorgon314 Demogorgon314 force-pushed the Demogorgon314/cpp-inclusive-seek branch from 0ba3d01 to 2320b95 Compare September 9, 2022 00:30
@BewareMyPower
Copy link
Contributor

BewareMyPower commented Sep 22, 2022

@RobertIndie @merlimat Could any of you leave a 2nd review?

@Demogorgon314
Copy link
Member Author

Ping @RobertIndie @merlimat

@Demogorgon314 Demogorgon314 merged commit 7e4c746 into apache:master Sep 28, 2022
@Demogorgon314 Demogorgon314 deleted the Demogorgon314/cpp-inclusive-seek branch September 28, 2022 02:08
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type/feature The PR added a new feature or issue requested a new feature
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[feature request] C++ and Python support inclusive seek
4 participants