kafka消息队列的两种模式

news/2024/11/9 0:51:12/

第一种模式:
点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除)
1.消息生产者生产消息发送给队列,然后消费者从队列中取出并且消费消息
2.消息被消费以后,queue中不再有存储,所有消息消费者不可能消费到已经被消费的消息
3.队列支持多个消费者,但对一个消息而言,只有一个消费者可以消费。
第二种模式:
发布订阅模式
1.消息生产者将消息发到topic,可以有多个topic.
2.同时有多个消息消费者订阅消费该消息,消费数据后不会被删除。
3.每个消费者相互独立,都可以消费到数据。

kafka中的一些名词:
主题:事件被组织持久的存储在主题中。kafka中的主题始终是多生产者和多订阅者:一个主题可以N个向其写入事件的生产者,以及订阅这些事件的N个消费者。主题中的事件可以根据需要随时读取雨传统的消息传递系统不同,事件被消费后不会被删除,相反,您可以通过每个主题的配置设置来定义kafka应该将你的事件保存多久,之后老的事件被丢弃。kafka适合长时间存储数据。

broker:主要功能就是持久化消息以及将消息队列中的消息从发送端传输到消费端。一个broker通常以服务器的形式出现,一台kafka服务器就是一个broker.一个集群由多个broker组成。一个broker可以容纳多个topic.如果kafka只有一个broker,就会出现单点故障。

一个分区只能被同一个消费这组中的消费者消费

启动
kafka-server-start.sh -daemon /opt/kafka/config/server.properties
生产者:kafka-console-producer.sh
消费者:kafka-console-consumer.sh
topic:kafka-topic.sh


http://www.ppmy.cn/news/64037.html

相关文章

【Python 正则表达式】零基础也能精通的正则表达式学习路线与参考资料

文章目录 一、正则表达式基础二、进阶知识三、优秀实践参考资料: 一、正则表达式基础 正则表达式是一种用来描述字符模式的语言,它可以用来匹配、查找、替换字符串中的文本。在Python中,我们可以使用re模块来操作正则表达式。 正则表达式基…

代数余子式怎么求

代数余子式是矩阵中每个元素的代数余数,可以通过以下步骤求得: 1. 找到该元素所在的行和列,将其删除,得到一个新的矩阵。 2. 计算新矩阵的行列式,乘以(-1)^(行号列号),即为该元素的代数余子式。 例如 对…

迎接内卷吧,GPT带来的失业潮才刚开始

在讨论具体问题之前呢咱们要明白 汽车刚刚被发明出来的时候呢 马车也不是说马上就消失了 还是流行了一段时间呢 新事物替代旧事物呢需要一个过程 当然了这次似乎不太一样 在过去的几个月时间里呢 人工智能方面的讨论太多了 这玩意的发展速度也太快了 几乎所有受过高等教育的同学…

二维图 CAD图 方案设计

胶带式纸箱开箱机2000L一机一缸分散釜示意图2.5KW_30传动比的蜗轮蜗杆减速机装配图(课程设计)L1C02JH3螺旋压紧机构DWBS500.5稳定土500搅拌机主机全套图纸G4-73-11-NO22。5D风机图轧机后升降台装配图L4100柴油机曲柄连杆机构,毕业设计全部文件…

基于S/Key协议的身份认证系统设计与实现【python】

实验内容 1 、 身份认证系统设计 设计身份认证系统的功能、主要界面、主要软件模块,以及采用的认证技术路线和方法。 2 、 编程实现所设计的身份认证系统 在C、Python或Java程序设计环境下,编程实现基于S/Key协议的身份认证系统。要求实现的身份认证…

8年测试开发,写给1-3年功能测试的几点建议,满满硬货指导

从15年毕业到现在也从业八年了,普通本科毕业,现在一家互联网公司担任测试部门总监,摸爬打滚,坑坑洼洼也经历了不少。思绪很久决定还是写下这篇,希望对后进的小伙子少走一点弯路。 很多人把职场想得太美好,其…

ubuntu 卸载 软件包 libfdt-dev

编译环境 Win10 64位 ubuntu 20.04 虚拟机 VMware Workstation 16 Pro NUC980 bsp 自带的编译工具链: nuc980bsp.tar.gz,版本 gcc version 4.8.4 (GCC) NUC980 uboot : https://gitee.com/OpenNuvoton/NUC970_U-Boot_v2016.11 目标 手动编译 NUC9…

目标检测YOLO实战应用案例100讲-基于YOLOv3的目标检测研究及改进(论文篇)

知识拓展 多尺度特征学习 目前深度学习用于目标检测已经习以为常。从SSD到Yolo系列,其中: 深层网络的感受野比较大,语义信息表征能力强,但是特征图的分辨率低,几何信息的表征能力弱(空间几何特征细节缺乏); 低层网络的感受野比较小,几何细节信息表征能力强,虽然分辨…