fFee-ops's Blog
kafka顺序消息 kafka顺序消息
场景概述假设我们要传输一批订单到另一个系统,那么订单对应状态的演变是有顺序性要求的。已下单 → 已支付 → 已确认不允许错乱! 顺序级别1)全局有序:串行化。每条经过kafka的消息必须严格保障有序性。这就要求kafka单通道,每个grou
2022-02-13
kafka底层架构 kafka底层架构
1. 存储架构1.1 分段存储kafka每个主题可以有多个分区,每个分区在它所在的broker上创建一个文件夹。每个分区又分为多个段,每个段有两个文件,log文件里顺序存消息,index文件里存消息的索引。段的命名直接以当前段的第一条消息的
2022-02-12
Springboot整合kafka Springboot整合kafka
1. 整合kafka1、引入依赖 <dependency> <groupId>org.springframework.kafka</groupId> <
2022-02-09
kafka架构探索及安装 kafka架构探索及安装
1. 发展历程https://kafka.apache.org/downloads 1.1 版本命名Kafka在1.0.0版本前的命名规则是4位,比如0.8.2.1,0.8是大版本号,2是小版本号,1表示打过1个补丁。 现在的版本号命名规则
2022-02-05
kafka创建主题出错:zookeeper is not a recognized option kafka创建主题出错:zookeeper is not a recognized option
原因选项zookeeper已弃用 解决把选项zookeeper替换为--bootstrap-server来使用
2022-02-05
kafka基础组件 kafka基础组件
角色 broker:节点,就是你看到的机器,也就是一个kafka服务 provider:生产者,发消息的 consumer:消费者,读消息的 zookeeper:信息/注册中心,记录kafka的各种信息的地方 controller:其中的
2022-02-05
kafka简介 kafka简介
1. 应用场景1.1 kafka场景Kafka最初是由LinkedIn公司采用Scala语言开发,基于ZooKeeper,现在已经捐献给了Apache基金会。目前Kafka已经定位为一个分布式流式处理平台,它以 高吞吐、可持久化、可
2022-02-04