if connector restart, if will lose data.

[penghuazhou]

Because consumer data into blockingQueue, if connector restart, it will lose data.

https://github.com/apache/rocketmq-connect/blob/85da68c92f599f0a289c0e63de919ca417289f69/connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSourceTask.java#L112C43-L112C56