streamnative / pulsar-spark

Spark Connector to read and write with Pulsar
Apache License 2.0
113 stars 50 forks source link

[FEATURE] Configuring Subscription mode to Shared #173

Open moweonlee opened 9 months ago

moweonlee commented 9 months ago

I have search all the internet to configure subscription to Shared.

But I haven't found it yet.

All I know is that since setting subscriptionType in java client requires Class variable, I don't know how to pass "SubscriptionType.Shared" in spark option.

Is there anyway to change subscription type to Shared ?

If not, I'd like to request subscriptionType option.

Because my spark batch process always read Pulsar from from earliest to latest even it require only 1 hour.