当前位置: 首页 > news >正文

大数据面试题:Kafka的单播和多播

面试题来源:

《大数据面试题 V4.0》

大数据面试题V3.0,523道题,679页,46w字

参考答案:

1、单播

一条消息只能被某一个消费者消费的模式称为单播。要实现消息单播,只要让这些消费者属于同一个消费者组即可。当生产者发送一条消息时,两个消费者中只有一个能收到消息。

2、多播

一条消息能够被多个消费者消费的模式称为多播。之所以不称之为广播,是因为一条消息只能被Kafka同一个分组下某一个消费者消费,而不是所有消费者都能消费,所以从严格意义上来讲并不能算是广播模式,当然如果希望实现广播模式只要保证每个消费者均属于不同的消费者组。针对Kafka同一条消息只能被同一个消费者组下的某一个消费者消费的特性,要实现多播只要保证这些消费者属于不同的消费者组即可。然后通过生产者发送几条消息,可以看到不同消费者组的消费者同时能消费到消息,然而同一个消费者组下的消费者却只能有一个消费者能消费到消息。

http://www.lryc.cn/news/102571.html

相关文章:

  • python与深度学习(八):CNN和fashion_mnist二
  • 开发一个RISC-V上的操作系统(五)—— 协作式多任务
  • Mybatis-plus集合
  • C++ 结构体和联合体
  • 使用TensorFlow训练深度学习模型实战(下)
  • lucene、solr、es的区别以及应用场景
  • Java方法的使用(重点:形参和实参的关系、方法重载、递归)
  • 登录页的具体实现 (小兔鲜儿)【Vue3】
  • 大学如何自学嵌入式开发?
  • pytorch学习——线性神经网络——1线性回归
  • 00 - RAP 开发环境配置
  • 山西电力市场日前价格预测【2023-08-01】
  • QT--day5(网络聊天室、学生信息管理系统)
  • 【用IDEA基于Scala2.12.18开发Spark 3.4.1 项目】
  • HEVC 速率控制(码控)介绍
  • 四大软件测试策略的特点和区别(单元测试、集成测试、确认测试和系统测试)
  • ingress-nginx controller安装
  • 开源快速开发平台:做好数据管理,实现流程化办公!
  • 基于深度学习的裂纹图像分类研究(Matlab代码实现)
  • TypeScript入门学习汇总
  • Vue3使用vxetable进行表格的编辑、删除与新增
  • JUC 并发编程之JMM
  • k8s集群中安装kibana 7.x 踩坑
  • CSS的一些基础知识
  • 解决多线程环境下单例模式同时访问生成多个实例
  • 转转闲鱼交易猫源码搭建
  • 设计模式精华版汇总
  • uniapp实现带参数二维码
  • 金融行业软件测试面试题及其答案
  • 强化学习QLearning 进行迷宫游戏和代码