Kafka 安装教程 + nodejs 连接

1、kafka安装包

http://kafka.apache.org/downloads

2、zookeeper安装包

https://zookeeper.apache.org/releases.html#download

1、先安装运行zookeeper

2、安装运吵拿行kafka

修改下图ip

advertised.listeners=PLAINTEXT://71.24.89.191:9092

这里主要是检测对应的端口是否是打开状态

分别是 zookeeper的默认端口 2181 和 kafka的 9092

检测网址

1、 添加

2、查看升散搭所有主题

3、查看主题掘毁下所有分区

4、动态 修改主题 分区为12

小伙伴们可以看我另一片文章

Nodejs kafka连接

1、内存不足

这里因为我的机器的内存比较小

OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000e0000000, 536870912, 0) failederror='Cannot allocate memory' (errno=12)

There is insufficient memory for the Java Runtime Environment to continue.

Native memory allocation (mmap) failed to map 536870912 bytes for committing reserved memory.

我们只需要把kafka启动脚本修改一下就可以了

修改内存为256:

systemctl daemon-reload

systemctl enable zookeeper

启动zk：systemctl start zookeeper

停止zk：systemctl stop zookeeper

reboot 验证

安装目录：/usr/local/kafka_2.13-2.7.0/

数据目录：/kafka/data

服务端口：9092

设置开机启动：

/etc/systemd/system/ 文件夹下创建一个启动脚本 kafka.service

chmod 755 kafka.service

设置文件内容：

systemctl daemon-reload

systemctl enable kafka

启动：systemctl start kafka

停止：systemctl stop kafka

上传nginx安握迟装包

yum -y install gcc gcc-c++ autoconf automake make zlib-developenssl openssl-devel

tar -zxvf nginx-1.16.1.tar.gz

cd nginx-1.16.1/

./configure —prefix=/usr/local/nginx

make&&make install

cd /usr/local/nginx/sbin

./nginx

lsof -i:80

检查是否安装成功消皮洞： http://10.10.108.2:80/

设置开机自启：

/etc/systemd/system/ 文件夹下创建一个启动脚本 nginx.service

chmod 755 nginx.service

设置文件内容：

systemctl daemon-reload

systemctl enable nginx

启动：systemctl start nginx

停止：拿枯systemctl stop nginx

reboot 验证是否开机自启

在新发布的kafka2.8.0版本中，已经可以不启动zk就可以使用kafka了，在config目录下多了一个kraft目录，在该目录中有一套新的配置文件，可以直接脱离ZooKeeper运行。

到kraft目录中修改server.properties文件，单机的话主要是修改下面的配置

需要把localhost修改卜芹厅为ip地址，否者别的节点连不上kakfa。

测试是否可以连接可以使用如下命令：首运

通过现在三行命令，即可开启一个单机的broker

这样脱离ZooKeeper的kafka就启动了，当前版本还型隐是测试阶段，所以官方不推荐使用。

---