apache/pulsar-adapters

pulsar-adapters unsupported consumer replicateSubscriptionState

slowpao opened this issue · 1 comments

slowpao commented

Is your enhancement request related to a problem? Please describe.
To consume messages across clusters in pulsar, you need to replicate the subscription state

Describe the solution you'd like
PulsarConsumerKafkaConfig.getConsumerBuilder() function add replicateSubscriptionState configuration item

tisonkun commented

Thanks for your reporting! I file a PR for pass through this option - #52

I'll appreciate it if you can test it out.