有如下几个方案吧：首推FlinkCDC其次就是比较典型的：mysql的binlog -> Canal -> Kafka -> Flink/Spark -> Hive/KuduOracle的redolog -> Ogg -> Kafka -> Flink/Spark -> Hive/Kudu