PS:
- Windows不是良好的运行环境
- 运行Kafka必须要先运行Zookeeper。可以使用内置的Zookeeper,也可以使用另外安装的Zookeeper
- 文件描述符限制,官方建议至少使用100000个文件描述符作为起点
- 设置合适的vm.max_map_count
1. 下包
$ wget https://mirror.bit.edu.cn/apache/kafka/2.5.0/kafka_2.12-2.5.0.tgzs
2. 配置
这里进行单机伪分布式配置 (就一台服务器,开多个端口,模拟分布式)
- 复制三份server.properties,修改其中的port、broker.id、log.dirs
- server1.properties
# Kafka broker节点唯一标识
borker.id=0
# 端口号(伪分布式不能冲突)
port=9092
# 对客户端提供的服务器地址和端口,xxxx改成自己的服务地址
advertised.listener=PLAINTEXT://xxxx:9092
# Kafka日志存分路径
log.dirs=/opt/software/kafka/kafka_2.12-2.5.0/logs/broker-0
# zk连接地址,最后带上目录(这样就能在一个zk上部署多个kafka集群)
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183/kafka_test
- server2.properties、server3.properties这里不贴了,修改对应参数
3. 运行
# 方式一
$ ./kafka-server-start.sh ../config/server.properties &
$ ./kafka-server-start.sh ../config/server1.properties &
$ ./kafka-server-start.sh ../config/server2.properties &
# 方式二 - 以守护进行方式
$ ./kafka-server-start.sh -daemon ../config/server.properties &
$ ./kafka-server-start.sh -daemon ../config/server.properties1 &
$ ./kafka-server-start.sh -daemon ../config/server.properties2 &
4. 停止服务
$ ./kafka-server-stop.sh