Consumption duplication

apache / rocketmq-flink

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.

https://rocketmq.apache.org/

Apache License 2.0

139 stars 88 forks source link

Consumption duplication #81

Open godfather1103 opened 1 year ago

godfather1103 commented 1 year ago

Data duplication during consumption in the demo

godfather1103 commented 1 year ago

RocketMQFlinkExample.txt

godfather1103 commented 1 year ago

BukJiang commented 1 year ago

comment out these lines of code

godfather1103 commented 1 year ago

This works