文章目录
特性
扩展,容错,高并发,持久性
对topic可以分区,之后可以对分区进行消费操作
流程
Topic
Topic 包含多个 Paritition.
Broker
包含多个Server. 每个Server包含一个Paritition 和 replica
其中有Leader Server 和 多个 Follower Server
Replica
ASR: Assigned
ISR: In-Sync-Assigned
OSR: Out-Sync_Assiigned
HW: Height Watermark: 高水位,消费者只能消费到这个 offset 之前的消息
LEO: Log-End-Offset,日志末端偏移,Partition 中 底层 日志 下一条消息的偏移. 如果 LEO = 10.
那么此 Partition 中存储10条消息
搭建kafka
kafka是 scala 编写的.
启动配置
bin/kafka-server-start.sh config/server.properties
可以查看 config/server.properties 中的配置
需要配置 broker.id , broker.listeners,log目录以及 zookeeper的服务地址
start zoo
启动 zookeeper. 之后可以使用 可视化工具连接. 或者直接命令查是否启动成功
./zkServer.sh config/zoo.cfg start
这个命令中有 zookeeper 的配置
start kafka
启动kafka
kafka 也需要配置 server.properties 文件.
在 config 下有各种的配置你文件
Server.properties
配置 zoo 的地址
broker.id 的序号
和自己的地址 listeners
log 的地址
报错
主要是 自己机器配置太小了 .于是修改了 kafka-server.start.sh 中 的配置
不过就算这么改.之后也还是报错了.启动成功,之后报了个这个
都怪博主太穷了.导致kafka都启动不起来.启动了,也自己停掉
信息解读
在启动 kafka 成功之后,会弹出 KafKaConfig 的数据