RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
Why is it that when "consumer.offset.reset.to" is set to "earliest", Flink will consume from the earliest offset instead of the submitted offset every time it is started,.
ShannonDing
commented
1 year ago
Why is it that when "consumer.offset.reset.to" is set to "earliest", Flink will consume from the earliest offset instead of the submitted offset every time it is started,.