前言：之前使用confluent已经出过文档，因为confluent插件比较老，小编只是演示用，而且confluent对应数据的更新删除不好识别，这次小编使用的是debezium搭配单机的kafka环境，演示以单机环境为主，但会说到集群。1.环境1.1、Kafka：kafka_2.13-2.8.01.2、数据库：/Oracle11G。（Oracle开启归档）1.3、计算引擎：Flink 1.13.