Debezium概述Debezium是用于捕获变更数据的开源分布式平台。可以响应数据库的所有插入，更新和删除操作。Debezium依赖于kafka上，所以在安装Debezium时需要提前安装好Zookeeper，Kafka，以及Kakfa Connect。Kafka ConnectKafka Connect用于在Apache Kafka和其他系统之间可扩展且可靠地数据流传输数据的工具，连接器可以轻

bin/kafka-console-consumer.sh --bootstrap-server pDataHadoop05:9092 --topic dtinsure_mongo3.kbc_mpls_prod.InsurePlan2021 --from-beginningbin/kafka-console-consumer.sh --bootstrap-server pDataHadoop05:

第1章 debezium概述1.1 debezium是什么Debezium 是一组分布式服务，用于捕获数据库中的更改，以便您的应用程序可以查看这些更改并对其做出响应。 Debezium 在更改事件流中记录每个数据库表中的所有行级更改，应用程序只需读取这些流以查看更改事件发生的相同顺序。1.2 debezium的依赖Debezium 构建在 Apache Kafka 之上，并提供与 Kafka Co

bin/kafka-console-consumer.sh --bootstrap-server xxx05:9092 --topic xxx_mongo.xxx2021 --from-beginni