[Bug][Connector] RocketMQ Source Get Start Offset

[liuxiaocs7]

What happened

The logic seems not right, when conf is earliest, it should be seekToBegin instead, vice versa?

  private long getStartOffset(MessageQueue messageQueue) throws MQClientException {
    switch (consumerOffsetMode) {
      case RocketMQSourceOptions.CONSUMER_OFFSET_EARLIEST_KEY:
        consumer.seekToEnd(messageQueue);
        return consumer.getOffsetStore()
            .readOffset(messageQueue, READ_FROM_MEMORY);
      case RocketMQSourceOptions.CONSUMER_OFFSET_LATEST_KEY:
        consumer.seekToBegin(messageQueue);
        return consumer.getOffsetStore()
            .readOffset(messageQueue, READ_FROM_MEMORY);
      case RocketMQSourceOptions.CONSUMER_OFFSET_TIMESTAMP_KEY:
        return consumer.offsetForTimestamp(messageQueue, consumerOffsetTimestamp);
      default:
        throw BitSailException.asBitSailException(
            RocketMQErrorCode.CONSUMER_FETCH_OFFSET_FAILED,
            String.format("Consumer offset mode = %s not support right now.", consumerOffsetMode));
    }
  }

What do you expect to happen

No response

How to reproduce

No.

Build Environment

No response

Execution Environment

No response

BitSail version

master

BitSail Component or Code Module

BitSail Connector

Are you willing to submit PR?

• [X] Yes, I am willing to submit a PR!

Code of Conduct

• [X] I agree to follow this project's Code of Conduct