Flink通过抽取Mysql增量数据到Hbase,期间做新旧数据对比统计
mysql_kafkapackage com.dl.kafka;import com.adt.entity.ShareHolder;import com.adt.vo.TimeStamp;import org.apache.kafka.clients.producer.KafkaProducer;import org.apache.kafka.clients.producer.Pro...