Flink CDC、Canal与Maxwell：数据库同步工具的比较
Flink CDC、Canal和Maxwell都是用于数据库同步的工具，它们可以帮助开发者和数据工程师实时捕获…
FlinkCDC消费MySQL Binlog 并推送到Kafka(三)（Canal CDC Format： canal-json）
Docker快速拉起Flink集群 、MySQL服务并打开GTID FlinkCDC消费MySQL Binlo…
FlinkCDC消费MySQL Binlog 并推送到Kafka(二)（Debezium CDC Format： debezium-json）
Kafka消息中字段解释 before：表示的是修改之前的数据 after：表示的是修改之后的数据 op：操作…
FlinkCDC消费MySQL Binlog 并推送到Kafka(一)
FlinkCDC消费MySQL Binlog 并推送到Kafka(一) 环境：Flink Version: 1…
Kafka 实际生产集群配置和记录
Kafka 实际生产集群配置和记录 三台机器配置：16核48G 2TB SSD 千兆网卡 早高峰流量约为空闲期…
ClickHouse为什么那么快？
一、MySQL数据库如何读区并查询数据的 以最常见的mysql为例，一条简单的查询语句是如何执行的，然后再以c…
kafka异步复制配置，kafka跨集群同步消息配置
kafka异步复制配置，kafka跨集群同步消息配置，connect-mirror-maker.propert…
HDFS冷热存储
《HDFS冷热存储》，Hadoop3.x支持HDFS目录级别配置异构存储，不同路径制定不同的存储策略。 一、H…
ClickHouse-Kafka引擎， 高可用实时落地生产方案
ClickHouse-Kafka引擎，高可用实时落地生产方案。这里以抽取event=cppla的信息为例，详细…
ClickHouse-Kafka引擎，如何将同一消息流中不同的消息分拆到不同的目标表
《ClickHouse-Kafka引擎，如何将同一消息流中不同的消息分拆到不同的目标表》，ClickHouse…