Debezium 采集Postgrsql数据变更到Kafka
作者:互联网
一、目的
利用Debezium
实时采集Postgrsql
的数据变更,到Kafka
用于后续操作日志审计。
官网参考地址:https://debezium.io/docs/connectors/postgresql/
二、基于Docker组件安装
2.1 zookeeper安装
docker run -itd --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:latest
2.2 kafka安装
docker run -itd --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:latest
2.3 postgresql安装
docker run -itd --name postgres -p 5432:5432 -e POSTGRES_PASSWORD=postgres -d debezium/example-postgres:latest
2.4
标签:run,postgres,--,Postgrsql,zookeeper,Kafka,debezium,itd,Debezium 来源: https://blog.csdn.net/ctwy291314/article/details/113707770