debezium1.8版本的安装步骤，其中包括：外网和内网的安装详细步骤。
2022-04-15 16:03:07
16KB
Flink-connector-debezium
基于Red Hat开源的Debezium组件，和Flink结合，实现在Flink上直接监听各种数据库的Change Log，并且能够利用Flink的特性，输出到不同的位置上，以实现数据总线和实时数仓的构建。此项目主要应用于数据中台或数据平台中数据总线的基础底座。
目前Debezium支持了MySQL、MongoDB、PostgreSQL、Oracle、SQL Server、Db2和Cassandra。理论上此连接器也支援以上所有数据库。
Getting Started
mvn clean package -DskipTests
example
参考DebeziumSourceITCase
2021-09-17 01:50:43
20KB
1
使用Flink丰富Kafka流与另一个流
环境设定
安装PostgreSQL 11+
设置PostgreSQL以允许使用pgoutput将Debezium转换为CDC。 参考
在您的机器/集群上设置Apache Kafka（使用Kafka Connect）
从安装Debezium PostgreSQL连接器
运行Apache Kafka和Kafka Connect
在PostgreSQL中创建表transactions和customers （SQL文件）
使用请求主体向您的Kafka Connect REST接口创建POST请求，如下所示
{
" name " : " postgres_cdc " ,
" config " : {
" connector.class " : " io.debezium.connector.postgresql.PostgresCon
2021-08-25 17:35:15
67KB
1
sql server2008 cdc 数据实时同步到kafka，Debezium是捕获数据实时动态变化的开源的分布式同步平台。能实时捕获到数据源（Mysql、Mongo、PostgreSql）的：新增（inserts）、更新(updates)、删除(deletes)操作，实时同步到Kafka，稳定性强且速度非常快。
2021-08-04 20:25:29
1.75MB
1
debezium-connector-oracle
2021-06-22 20:03:41
6.49MB
1
保险丝-openshift-debezium-教程
使用JBoss Fuse Integration Service使用者样本完成了OpenShift上的。
先决条件
假定您正在运行某种可用的OpenShift集群实例。 此实例可以采用多种形式，具体取决于您的环境和需求：
您站点上的完整OpenShift集群，请参阅如何上 ，
笔记本电脑上的Red Hat容器开发套件，了解如何 ，
笔记本电脑上的轻量级Minishift，请参见。
您还应该在计算机上安装oc客户端线路接口工具。 从此选择相应的OpenShift版本。 尽管我已经在OpenShift 3.9集群上部署并测试了所有内容，但它也应与以前的3.7版本一起使用。
教程设置
首先，首先创建一个专用的debezium项目，以便在您喜欢的OpenShift实例上运行本教程。 您必须确保参与本教程的其余部分。
oc new-pro
2021-04-30 12:03:19
584KB
1
基于Kafka的数据同步服务搭建，内容涵盖Kafka部署，Kafka安全配置，跨DC，数据加密，认证等诸多元素
2021-01-28 12:19:03
220KB