专栏首页M莫的博客Docker方式启动Connect Debezium

Docker方式启动Connect Debezium

以docker的方式启动debezium。

  • Start Zookeeper 1 docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:0.8
  • Start Kafka 1 docker run -it --rm --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:0.8
  • Start a MySQL database 1 docker run -it --rm --name mysql -p 3306:3306 -e MYSQL_ROOT_PASSWORD=debezium -e MYSQL_USER=mysqluser -e MYSQL_PASSWORD=mysqlpw debezium/example-mysql:0.8
  • Start Kafka Connect 1 docker run -it --rm --name connect -p 8083:8083 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPIC=my_connect_configs -e OFFSET_STORAGE_TOPIC=my_connect_offsets --link zookeeper:zookeeper --link kafka:kafka --link mysql:mysql debezium/connect:0.8
  • Connect the MySQL database 1 curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d '{ "name": "inventory-connector", "config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector", "tasks.max": "1", "database.hostname": "mysql", "database.port": "3306", "database.user": "debezium", "database.password": "dbz", "database.server.id": "184054", "database.server.name": "dbserver1", "database.whitelist": "inventory", "database.history.kafka.bootstrap.servers": "kafka:9092", "database.history.kafka.topic": "dbhistory.inventory" } }'
  • Monitor the MySQL database 1 docker run -it --name watcher --rm --link zookeeper:zookeeper debezium/kafka:0.8 watch-topic -a -k dbserver1.inventory.customers

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Jib构建你的第一个java镜像

    首先我们先看一个例子,如何将一个spring-boot项目简单容器化,如果你从未操作过,可以动手自己实现,或者仔细阅读这篇文章第一个 spring Boot 应...

    XING辋
  • Debezium结合kafka connect实时捕获mysql变更事件写入elasticsearch实现搜索流程

    本文将会实现一套完整的Debezium结合Kafka Connect实时捕获MySQL变更事件写入Elasticsearch并实现查询的流程.

    XING辋
  • Mysql实时数据变更事件捕获kafka confluent之debezium

    如果你的后端应用数据存储使用的MySQL,项目中如果有这样的业务场景你会怎么做呢?

    XING辋
  • 数据库之数据表控制语句

    3、设置值的唯一性(不允许重复数据,可以为空,但只能有一个空,否则就会被视为重复)

    小手冰凉
  • Java EE实用教程笔记----(1)第1章 Java EE平台及开发入门

    最近从图书馆借了本JavaEE实用教程(第3版),打算学习SSH和SSM框架,特此做笔记,以飨读者.

    浩Coding
  • spring 在启动服务器的时候报错 Could not open ServletContext resource [/WEB-INF/dispather-servlet.xml]

     java.io.FileNotFoundException: Could not open ServletContext resource [/WEB-IN...

    bear_fish
  • RobotFramework怎么写好用例

    github地址:https://github.com/robotframework/HowToWriteGoodTestCases/blob/master/H...

    苦叶子
  • 大神 | EfficientNet模型的完整细节

    本文介绍了一种高效的网络模型EfficientNet,并分析了 EfficientNet B0 至B7的网络结构之间的差异。

    计算机视觉联盟
  • RobotFramework怎么写好用例

    github地址:https://github.com/robotframework/HowToWriteGoodTestCases/blob/master/H...

    苦叶子
  • 热传导问题的数值解法Edition4

    关于本科《传热学》简单温度场数值求解,早先有2018年的视频: 一维常物性无内热源无穷大平板温度场数值模拟(基于基于HTML5编程)。2019年重新录...

    周星星9527

扫码关注云+社区

领取腾讯云代金券