inlong
inlong copied to clipboard
[Feature][Manager] Support configuration of subscription name for pulsar source
Description
Currently, we can't set the subscription name for the pulsar source,
Flink connector will generate a subscription name combining flink-sql-connector-pulsar
prefix with a random string suffix.
This may lead to the flink job failing due to the subscription not existing in the pulsar broker(the pulsar broker may disable the auto-creation of subscription).
Use case
Manager supports setting the subscription name for the pulsar source and passes the parameter to flink-pulsar-connector.
Are you willing to submit PR?
- [ ] Yes, I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct