Closed liyubin117 closed 2 years ago
@liyubin117, do you mean that the table opion of the RocketMQ source has no consumer.offset.reset.to
opion?
@liyubin117, do you mean that the table opion of the RocketMQ source has no
consumer.offset.reset.to
opion?
yes, very weird
@liyubin117 , do you want to contribute this table option?
@SteNicholas I'm very interested in this,please assign the issue to me.
@SteNicholas sorry for the late reply, I am very glad to make a pull request. :)
@SteNicholas Hi, could you please give a review? Thanks :)
as document figured,
consumer.offset.reset.to
can be used to identify initial offset, in fact, throw exception as follow: