feat(pulsar): support subscribeInitialPosition on Pulsar consumer

[ericsyh]

Description

SubscriptionInitialPosition is the start consuming position for Pulsar subscription. Similar to Apache Kafka's initialOffset.

• https://pkg.go.dev/github.com/apache/pulsar-client-go/pulsar#SubscriptionInitialPosition
• https://v1-12.docs.dapr.io/reference/components-reference/supported-pubsub/setup-apache-kafka/

Issue reference

We strive to have all PR being opened based on an issue, where the problem or feature have been discussed prior to implementation.

Please reference the issue this PR will close: #[issue number]

Checklist

Please make sure you've completed the relevant tasks for this PR, out of the following list:

• Code compiles correctly
• Created/updated tests
• Extended the documentation / Created PR in feat(pulsar): support subscribeInitialPosition on Pulsar consumer docs#4582

[JoshVanL]

Thanks @ericsyh! Please could you open up a PR in the docs for this new field?

[ericsyh]

Thanks @ericsyh! Please could you open up a PR in the docs for this new field?

@JoshVanL Sure, i created the PR for doc update: dapr/docs#4582

[ericsyh]

@JoshVanL Hey Josh, Could you help give a reivew on this PR?

[cicoyle]

Hey @ericsyh thanks for the PR 🎉 - mind running the linter locally and resolving the issues?

[ericsyh]

Hey @ericsyh thanks for the PR 🎉 - mind running the linter locally and resolving the issues?

@cicoyle Hi Cassie, thx for your review and good catches. I just fixed the tests and run the lint locally. At least this PR doesn't introduce new lint issue from the output.

WARN The linter 'gomnd' is deprecated (since v1.58.0) due to: The linter has been renamed. Replaced by mnd.
WARN The linter 'execinquery' is deprecated (since v1.58.0) due to: The repository of the linter has been archived by the owner.
WARN [runner/nolint] Found unknown linters in //nolint directives: usetesting
pubsub/pulsar/pulsar.go:25:2                                                         typecheck  could not import sync/atomic (-: could not load export data: internal error in importing "sync/atomic" (unsupported version: 2); please report an issue)
pubsub/pulsar/pulsar.go:362:27                                                       typecheck  undefined: avro
pubsub/pulsar/pulsar.go:367:9                                                        typecheck  undefined: avro
make: *** [lint] Error 1

[ericsyh]

@cicoyle @JoshVanL @yaron2 hey guys, could you help take a look this PR? Since this PR is pending for review and the related doc PR dapr/docs#4582 was closed for stale.

[yaron2]

@cicoyle @JoshVanL @yaron2 hey guys, could you help take a look this PR? Since this PR is pending for review and the related doc PR dapr/docs#4582 was closed for stale.

Yes, apologies for the slow feedback. Workflows now running

[ericsyh]

@cicoyle @JoshVanL @yaron2 hey guys, could you help take a look this PR? Since this PR is pending for review and the related doc PR dapr/docs#4582 was closed for stale.

Yes, apologies for the slow feedback. Workflows now running

@yaron2 Sure that's fine. The CI workflow check passed, could you help take a review on it?

[marcduiker]

@holopin-bot @ericsyh Thank you! Here's a digital badge as a small token of appreciation.

[holopin-bot]

Congratulations @ericsyh, the maintainer of this repository has issued you a badge! Here it is: https://holopin.io/claim/cmbs0fdbg461407le4td1vc27

This badge can only be claimed by you, so make sure that your GitHub account is linked to your Holopin account. You can manage those preferences here: https://holopin.io/account.
Or if you're new to Holopin, you can simply sign up with GitHub, which will do the trick!