inlong icon indicating copy to clipboard operation
inlong copied to clipboard

[Feature][Manager] Support configuration of subscription name for pulsar source

Open aloyszhang opened this issue 10 months ago • 0 comments

Description

Currently, we can't set the subscription name for the pulsar source, image

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

aloyszhang avatar Mar 27 '24 08:03 aloyszhang