Repository navigation
[Bug] [connector]][rocketmq] rocketmq如果offset模式中，offset传入-1报错 #1836
Description
Search before asking
- 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
- I agree to follow this project's Code of Conduct
Activity
Wslibin commentedon Oct 16, 2023
case OFFSET:
offset =
rocketMQConf.getStartMessageOffset() < 0
? offset
: rocketMQConf.getStartMessageOffset();