学习用kafka Debezium来捕捉mysql变化
在注册完连接器之后测试一下：
创建kafka消费者：
向mysql插入数据
但是消费者没有任何反应，kafka connect没有报错。
查看kafka tools
可以看到连接器启动之前mysql变化的数据，但是刚刚mysql变化没有捕捉到。
浏览器http：local host：8083/connectors/mysql connector/status 查看连接器运行状态是running运行正常
这没有报错，我不知道问题出在哪里？
关于kafka Debezium捕获mysql问题
可以看到连接器启动之前mysql变化的数据，但是刚刚mysql变化没有捕捉到。
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
4条回答 默认 最新
三千烦恼丝xzh 2022-10-26 14:25关注MySQL binlog状态，连接器startup.model选项使用那种形式，最后不行在看debezium的日志
本回答被题主选为最佳回答 , 对您是否有帮助呢?评论 打赏解决 1无用举报 分享
- 2022-10-26 12:40回答 4 已采纳 MySQL binlog状态，连接器startup.model选项使用那种形式，最后不行在看debezium的日志
- 2022-06-11 10:41回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
- 2022-07-21 16:59回答 1 已采纳 内部是9092端口，外部用31082端口
- 2021-09-06 16:18八五年的湘哥的博客 Debezium依赖于kafka上，所以在安装Debezium时需要提前安装好Zookeeper，Kafka，以及Kakfa Connect，可以处理的数据源有很多，包括关系型数据库如MySQL,Oracle，SQL Server等，NoSQL数据如MongoDB，Cassandra等,是一...
- 2019-07-31 14:42回答 1 已采纳 用sslstream https://www.cnblogs.com/niuniu502/archive/2011/04/22/2024907.html
- 2018-07-21 14:46回答 1 已采纳 https://blog.csdn.net/weixin_40137479/article/details/79214312
- 2023-01-06 12:17回答 1 已采纳 是的。如果有副本的话，副本分区也有这个消息。
- 2022-10-04 15:25wespten的博客 Debezium是用于捕获变更数据的开源分布式平台。可以响应数据库的所有插入，更新和删除操作。Debezium依赖于kafka上，所以在安装Debezium时需要提前安装好Zookeeper，Kafka，以及Kakfa Connect。
- 2021-06-17 17:19回答 10 已采纳 https://blog.csdn.net/qq_40407889/article/details/118028472 java的kafka操作的简单demo
- 回答 1 已采纳 1. kafka的元数据信息是保存在zookeeper上的,可以通过zookeeper恢复对应关系,zookeeper中记录了broker的id 、消费者消费数据的offset,消费者与partit
- 2023-01-23 19:40回答 2 已采纳 看起来你好像少这个jar ： kafka-clients，查找一下项目里引用了没有 另外就是需要你check一下你代码里是否使用了 StringDeserializer 代替了 StringSer
- 2022-11-09 07:00老叶茶馆_的博客 Debezium介绍基本使用MySQL的准备工作编写程序测试总结一、Debezium介绍摘自官网:Debezium is a set of distributed services to capture changes in your databases so that your applications can see those ...
- 2023-01-14 04:00回答 1 已采纳 你要记录你的消费的offset从指定offset开始消费。如果有过消费记录的话。如果不指定就从eariest开始消费
- JackSparrow414的博客 sourceConnector.jar，将源数据导入至Kafka的topic中sinkConnector.jar，将Kafka topic中的数据导入至目标源但是Kafka并没有提供特别丰富的connector，那么Debezium就出现了。你可以把Debezium简单理解成是CDC技术的...
- 2023-09-15 16:36源码挖掘机的博客 实时数据平台中经常需要跨级群间做数据的同步，这个同步不仅包括数据的实时同步，还包括表结构的实时同步。这里我们经常用到的组件是Flink CDC，从下图我们...将Flink CDC读取到mysql的binlog变更数据发送到kafka中。
- 没有解决我的问题, 去提问
问题事件
系统已结题
11月3日
已采纳回答
10月26日-
创建了问题
10月26日
悬赏问题
- ¥20 机器学习能否像多层线性模型一样处理嵌套数据
- ¥20 西门子S7-Graph,S7-300，梯形图
- ¥50 用易语言http 访问不了网页
- ¥50 safari浏览器fetch提交数据后数据丢失问题
- ¥15 matlab不知道怎么改，求解答！！
- ¥15 永磁直线电机的电流环pi调不出来
- ¥15 用stata实现聚类的代码
- ¥15 请问paddlehub能支持移动端开发吗？在Android studio上该如何部署？
- ¥20 docker里部署springboot项目，访问不到扬声器
- ¥15 netty整合springboot之后自动重连失效