inlong
inlong copied to clipboard
[Feature][SortSdk] Support multi-topic manager
Description
Current consume policy is one kafka/pulsar consumer only consume one topic. Multi-topic policy is applied to those cases that all topics under this task share the same consumer strategy (such as roll back)
Use case
No response
Are you willing to submit PR?
- [X] Yes, I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct