Closed SteNicholas closed 1 year ago
Supports the startMessageOffset option for RocketMQSourceFunction.
startMessageOffset
RocketMQSourceFunction
Supports the
startMessageOffset
option forRocketMQSourceFunction
.