inlong
inlong copied to clipboard
[Umbrella][SortSdk] Refactor SortSdk
Describe the proposal
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)
Task list
- [x] #5495
- [x] #5496
- [ ] #5511
- [x] #5510
- [ ] #5560
- [x] #5665
- [ ] #5669
- [x] #5796
InLong Component
InLong SDK
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