aloyszhang opened a new issue, #9878:
URL: https://github.com/apache/inlong/issues/9878

   ### Description
   
   Currently, we can't set the subscription name for the pulsar source,
   <img width="655" alt="image" 
src="https://github.com/apache/inlong/assets/48062889/f6478926-e537-41ce-aa9b-55e402ea1ad4";>
   
   Flink connector will generate a subscription name with 
`flink-sql-connector-pulsar` prefix and 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](https://www.apache.org/foundation/policies/conduct)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to