Kafka系统学习(1)

cn123456789 发表于 2021/05/30 22:11:13 2021/05/30
【摘要】 Kafka是最初由Linkedin公司开发,是一个分布式、分区的、多副本的、多订阅者,基于ZooKeeper协调的分布式日志系统,常见可以用于web/nginx日志、访问日志,消息服务等等,Kafka在普通服务器上也能每秒处理数十万条消息,主要应用场景是:日志收集系统和消息系统。分布式消息传递基于可靠的消息队列,在客户端应用和消息系统之间异步传递消息。有两种主要的消息传递模式:点对点传递模式...

Kafka是最初由Linkedin公司开发,是一个分布式、分区的、多副本的、多订阅者,基于ZooKeeper协调的分布式日志系统,常见可以用于web/nginx日志、访问日志,消息服务等等,Kafka在普通服务器上也能每秒处理数十万条消息,主要应用场景是:日志收集系统和消息系统。

分布式消息传递基于可靠的消息队列,在客户端应用和消息系统之间异步传递消息。有两种主要的消息传递模式:点对点传递模式、发布-订阅模式。大部分的消息系统选用发布-订阅模式。Kafka就是一种发布-订阅模式。

(1) 点对点传递模式

在点对点消息系统中,消息持久化到一个队列中。此时,将有一个或多个消费者消费队列中的数据。但是一条消息只能被消费一次。当一个消费者消费了队列中的某条数据之后,该条数据则从消息队列中删除。该模式即使有多个消费者同时消费数据,也能保证数据处理的顺序。逻辑结构图:

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区),文章链接,文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:cloudbbs@huaweicloud.com进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。