chunjun icon indicating copy to clipboard operation
chunjun copied to clipboard

[Bug] [connector]][rocketmq] rocketmq如果offset模式中,offset传入-1报错

Open Wslibin opened this issue 2 years ago • 1 comments

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

Wslibin avatar Oct 16 '23 08:10 Wslibin

case OFFSET: offset = rocketMQConf.getStartMessageOffset() < 0 ? offset : rocketMQConf.getStartMessageOffset();

Wslibin avatar Oct 16 '23 08:10 Wslibin