kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来

文章目录

特性

扩展,容错,高并发,持久性
对topic可以分区,之后可以对分区进行消费操作

流程

kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来

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启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来

搭建kafka

kafka是 scala 编写的.
kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来

启动配置

bin/kafka-server-start.sh config/server.properties

可以查看 config/server.properties 中的配置 
需要配置 broker.id , broker.listeners,log目录以及 zookeeper的服务地址

kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来

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启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来
不过就算这么改.之后也还是报错了.
启动成功,之后报了个这个
kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来
都怪博主太穷了.导致kafka都启动不起来.
kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来
启动了,也自己停掉
kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来

信息解读

在启动 kafka 成功之后,会弹出 KafKaConfig 的数据
kafka学习值先把kafka启动了说吧哦对了还要买个2核4G的CPU要不然多跑不起来

上一篇:4G无线MQTT协议http倾角压力振动液位位移温湿度超声波流量风速风向降雨量CO2氧气烟雾电流应变传感变送器继电器对接阿里云onenet私有云


下一篇:Jvm参数调优