consumer就是接收producer发布的消息进行处理的应用。
上图描述了consumer消费消息的high-level层工作原理。consumer从broker内的topic订阅消息；然后consumer向lead broker发起请求，指定消息的offset。consumer使用这样的拉取模式，每次始终拉取它记录在日志中当前位置之后的所有消息。上图描述了con
阅读背景：
kafka学习五：开发consumer
来源：互联网
分享到：
