lzqdename opened a new issue #14281:
URL: https://github.com/apache/pulsar/issues/14281


   **Is your enhancement request related to a problem? Please describe.**
   in config file of pulsar io ,
   user can define the parallelism parameter,
   but there is a problem, for example
   In Mongodb Source, if this param is set to be 100000,
   when run in local run mode,100000 threads generated, but apparently this is 
wrong
   -
   besides this, in Mongo Source ,the parallelism just shoud be 1,
   
   based on the 2 reasons, the parallelism config can be decided finally by the 
SourceClass, just like kafka connect
   
   **Describe the solution you'd like**
   A clear and concise description of what you want to happen.
   
   **Describe alternatives you've considered**
   A clear and concise description of any alternative solutions or features 
you've considered.
   
   **Additional context**
   Add any other context or screenshots about the feature request here.
   


-- 
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