![[Kafka]学习笔记(一)连上公司的Kafka,第1张 [Kafka]学习笔记(一)连上公司的Kafka,第1张](/aiimages/%5BKafka%5D%E5%AD%A6%E4%B9%A0%E7%AC%94%E8%AE%B0%28%E4%B8%80%29%E8%BF%9E%E4%B8%8A%E5%85%AC%E5%8F%B8%E7%9A%84Kafka.png)
目前我是纯小白,没学过Kafka,但公司用这个来做事件监听的。
我发现我一启动项目怎么还是收到老的消息,和数据库不一致。那说明应该消息队列那边是积压消息了吧。
参考的这篇文章Kafka 可视化工具成功连上了!
注意要点启动按钮。在oldest那个选项下果然是老的消息,但是我启动项目后收到的消息还要更老,没搜索到。
在newest那边能看到最新的3条就是我手动修改数据库产生的,说明binlog日志监听到Kafak消息这步是没问题的。
而且怎么区分oldest和newest就不知道了,可能是根据偏移量。总之得学习下Kafka
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)