search

apache / pulsar-adapters

Apache Pulsar Adapters
https://pulsar.apache.org/
24 stars 31 forks source link

pulsar-adapters unsupported consumer replicateSubscriptionState #51

Closed slowpao closed 1 year ago

slowpao commented 1 year ago

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 1 year ago

Thanks for your reporting! I file a PR for pass through this option - https://github.com/apache/pulsar-adapters/pull/52

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