chunjun
chunjun copied to clipboard
[Bug] [connector]][rocketmq] rocketmq如果offset模式中,offset传入-1报错
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
rocketmq如果offset模式中,offset传入-1报错,通过代码查看offset赋值有问题
What you expected to happen
--
How to reproduce
--
Anything else
No response
Version
master
Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct
case OFFSET: offset = rocketMQConf.getStartMessageOffset() < 0 ? offset : rocketMQConf.getStartMessageOffset();