apache / pulsar-adapters

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

Auto update partition for pulsar kafka producer #28

Closed rdhabalia closed 2 years ago

rdhabalia commented 3 years ago

Motivation

Pulsar kafka producer doesn't update partition automatically if it changes at pulsar-client library. Add support to reflect change at pulsar-kafka producer if partitions are changed,