Closed humkum closed 1 month ago
In RocketMQSink.java, batchList's message maybe cleared by flushSync without send to broker
In RocketMQSink.java, batchList's message maybe cleared by flushSync without send to broker
![image](https://github.com/apache/rocketmq-flink/assets/50660789/7a6bac74-9223-4050-b542-4609f2a5eba1)