type
status
date
slug
summary
tags
category
icon
password
安装sqlserver
运行脚本等着安装完成
开启表的cdc
创建shihu数据库
建测试表
开启cdc
下载kafka插件
官方文档
https://debezium.io/documentation/reference/1.3/connectors/sqlserver.html ### 下载 https://repo1.maven.org/maven2/io/debezium/debezium-connector-sqlserver/1.2.5.Final/debezium-connector-sqlserver-1.2.5.Final-plugin.tar.gz
创建插件目录
在kafka跟目录创建 kafka_connect_plugins 目录 将下载的包解压到此目录中
修改kafka/config/connect-distribute.properties
bootstrap.servers=IP:9092 plugin.path= /kafka路径/kafka_connect_plugins
启动kafka-connect
开启成功的标志,postman可以使用访问端口8083（默认的端口号,可以在connect-distributed.properties 更改）
rest api
添加sqlserver connect
消费信息
consumer.preperties配置
修改器kafka-console-consumer.sh为kafka-console-consumer-saal.sh倒数第二行添加
启动
消息示例
oracle示例
mysql示例
查看topic list
- 作者:OldCamel
- 链接:https://blog.oldcamel.cc/article/4
- 声明:本文采用 CC BY-NC-SA 4.0 许可协议，转载请注明出处。
.png?table=collection&id=15236490-582e-8193-9b2a-000b631ec71c&t=15236490-582e-8193-9b2a-000b631ec71c&width=800&cache=v2)
