kafka浅谈
2024-10-01 18:59:00
关键词
producer 生产者
broker 缓存代理
consumer 消费者
partition 分区
topic 主题
group 群组
特点
1 高吞吐量
写入消息速度：25万/s
处理消息速度：55万/s
2 支持持久化操作，基于硬盘的吞吐，没有采用Cache，支持批量备份
3 支持分布式集群部署，易拓展，无需重启即可拓展生产者、消费者、缓存代理
4 消息处理状态存在消费者端，非kafka服务端。当一个消费者挂了后，其他消费者重新平衡
订阅Topic共享消息
一个消息需要多Consumer共同消费，需要为订阅了相同的Topic的Consumer分配不同的Group,不同Group可以共同消费同样的消息
Consumer配置
每个Topic对应的Partition数量至少应该等于消费者数量，保证消费者都可以消费到该Topic
Producer--kafka Broker--Consumer的关系
Producer--Topic--Partition--Consumer的关系
最新文章
- python 数据类型 ---字符串
- js cookie的封装和调用
- Echarts xAxis boundaryGap
- C语言break和continue
- EF联合查询的新用法
- 设置groupBox背景透明
- 题解西电OJ (Problem 1005 -跳舞毯)--动态规划
- xmlns:android="http://schemas.android.com/apk/res/android" 是什么意思？
- apk当安装程序将文件复制到手机自带的指定文件夹
- 不带插件 ，自己写js，实现批量上传文件及进度显示
- 初识ELF格式 ABI,EABI,OABI
- 有标号DAG计数 [容斥原理 子集反演 组合数学 fft]
- [转帖]Oracle 各个版本的升级路线图
- 初探kafka streams
- Hadoop大数据通用处理平台
- centos7只rsync+inotify
- spark-sql分组去重总数统计uv
- ----Androd 系统开机显示白条提示 “there is internal problem with your device， Contact your manufacture ... ”
- Nginx子域名配置
- MySQL 的主从原理和复制过程简述