vernedeng
vernedeng
### Description _No response_ ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct...
### 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...
### Description _No response_ ### InLong Component InLong SDK ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct...
### Description _No response_ ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct...
### 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...
### Describe the proposal In some case, the down stream system break down, we need to rollback a stream or a task with certain time interval. It require sort-standalone support...
### Description manager support handler a roll back task. 1. parse all topics need to roll back from interface getSortSource 2. reset all topics to the timestamp that expected to...
### Description _No response_ ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct...
### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-XYZ][Component] Title of the pull request *(The following *XYZ* should be replaced by the...
### Describe the proposal ### Task list - [x] #6042 - [x] #6086 - [x] #6101 - [ ] #6103 - [ ] #6104 ### InLong Component InLong Manager ###...