设为首页 加入收藏

TOP

kafka_Kafka的消息消费机制
2019-01-20 14:37:00 】 浏览:116
Tags:kafka_Kafka 消息 消费 机制

测试:

启动生产者与消费者。

使用zooinspector工具查看当前zook情况:

找到当前的消费者:(我也是一个一个找的)

可以看到当前的offsetskafkademo这个topic的值为359.

生产一条消息,同时消费者也消费了一条消息,再来刷新工具:

可以看到,此值变为了360,含意很明显了,kafka中共有360条消息,当前消费者已消费了360条(相当于索引值)

使用代码消费(对应上面图片中的group项),可以看到一样的效果:

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇问题修复:启动kafka服务器,显示.. 下一篇kafka消费者总结(三)

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目