> 文章列表 > Debezium系列之:基于Debezium实现Cassandra数据库数据实时接入Kafka集群的详细流程步骤

Debezium系列之:基于Debezium实现Cassandra数据库数据实时接入Kafka集群的详细流程步骤

Debezium系列之:基于Debezium实现Cassandra数据库数据实时接入Kafka集群的详细流程步骤

Debezium系列之:基于Debezium实现Cassandra数据库数据实时接入Kafka集群的详细流程步骤

  • 一、需求背景
  • 二、搭建Cassandra集群详细步骤
  • 三、Cassandra数据库开启CDC
  • 四、表级别开启CDC
  • 五、准备Debezium目录
  • 六、部署jar包
  • 七、创建config.properties
  • 八、创建log4j.properties
  • 九、准备创建表和数据插入sql
  • 十、创建超级用户,并执行sql
  • 十一、启动数据采集
  • 十二、总结

一、需求背景

  • 需要接入cassandra数据库数据到Kafka集群,提供下游flink程序实时消费Kafka Topic

二、搭建Cassandra集群详细步骤

  • Cassandra数据库从入门到精通系列之二:搭建Cassandra集群