BitSail is a distributed high-performance data integration engine which supports batch, streaming and incremental scenarios. BitSail is widely used to synchronize hundreds of trillions of data every day.
Title: [BitSail-458][Connector] Fix RocketMQ Source get start offset
Fixes: #458
Please change the PR title and the related issue number refer to the following description.
The above XYZ must be replaced with the actual GitHub Issue number, indicating that the current PR is used to solve the problem described in this Issue.
If you don't find an Issue that matches your changes, please Create Issue first, then commit this PR.
Prepare a Pull Request
Title: [BitSail-458][Connector] Fix RocketMQ Source get start offset
Fixes: #458
Motivation
Describe what this PR does and what problems you're trying to solve.
Modifications
Describe the modifications you've done.
Verifying this change
Please pick either of the following options.
[X] This change is a trivial rework/code cleanup without any test coverage.
[X] This change is already covered by existing tests, such as: (please describe tests, example:)
[X] This change added tests and can be verified as follows:
(example:)
Documentation