Linux系统之Kafka+Zookeeper(Kafka自带)单机伪集成部署
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Linux系统之Kafka+Zookeeper(Kafka自带)单机伪集成部署,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含3093字,纯文字阅读大概需要5分钟。
内容图文
Linux系统之Kafka+Zookeeper单机伪集成部署
文章目录
一、单机伪集成部署
1、准备
服务器一台ip:192.168.138.135
JDK:1.8
2、下载
从官方网站 kafka.apache.org/downloads 下载Kafka,目前新的版本Kafka都自带zookeeper。
3、安装
下载完毕,解压,没什么可说的。
4、zookeeper配置
因为kafka依赖zookeeper,所以先启动zookeeper服务
在/usr/local/kafka_2.12-2.8.0/config/目录下添加zookeeper1.properties,zookeeper2.properties,zookeeper3.properties配置文件,内容分别如下
- 配置
# zk 1
dataDir=/usr/local/kafka_2.12-2.8.0/logs/zookeeper/zookeeper-1
clientPort=2181
maxClientCnxns=0
initLimit=5
syncLimit=2
server.1=localhost:2666:3666
admin.serverPort=9191
# zk 2
dataDir=/usr/local/kafka_2.12-2.8.0/logs/zookeeper/zookeeper-2
clientPort=2182
maxClientCnxns=0
initLimit=5
syncLimit=2
server.2=localhost:2667:3667
admin.serverPort=9192
# zk 3
dataDir=/usr/local/kafka_2.12-2.8.0/logs/zookeeper/zookeeper-3
clientPort=2183
maxClientCnxns=0
initLimit=5
syncLimit=2
server.3=localhost:2668:3668
admin.serverPort=9193
- 添加启动脚本zookeeper-start-all.sh
[root@root bin]# pwd
/usr/local/kafka_2.12-2.8.0/bin
[root@root bin]# cat zookeeper-start-all.sh
#!bin/bash
nohup /usr/local/kafka_2.12-2.8.0/bin/zookeeper-server-start.sh /usr/local/kafka_2.12-2.8.0/config/zookeeper1.properties > /usr/local/kafka_2.12-2.8.0/logs/zookeeper/zookeeper-1/zk.log 2>&1 &
nohup /usr/local/kafka_2.12-2.8.0/bin/zookeeper-server-start.sh /usr/local/kafka_2.12-2.8.0/config/zookeeper2.properties > /usr/local/kafka_2.12-2.8.0/logs/zookeeper/zookeeper-2/zk.log 2>&1 &
nohup /usr/local/kafka_2.12-2.8.0/bin/zookeeper-server-start.sh /usr/local/kafka_2.12-2.8.0/config/zookeeper3.properties > /usr/local/kafka_2.12-2.8.0/logs/zookeeper/zookeeper-3/zk.log 2>&1 &
5、kafka配置
在/usr/local/kafka_2.12-2.8.0/config/目录下添加server1.properties,server2.properties,server3.properties配置文件,内容分别如下
- 配置
broker.id=1
listeners=PLAINTEXT://localhost:9092
log.dirs=/usr/local/kafka_2.12-2.8.0/logs/kafka/logs1
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183
broker.id=2
listeners=PLAINTEXT://localhost:9093
log.dirs=/usr/local/kafka_2.12-2.8.0/logs/kafka/logs2
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183
broker.id=3
listeners=PLAINTEXT://localhost:9094
log.dirs=/usr/local/kafka_2.12-2.8.0/logs/kafka/logs3
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183
- 添加启动脚本kafka-start-all.sh
[root@root bin]# pwd
/usr/local/kafka_2.12-2.8.0/bin
[root@root bin]# cat kafka-start-all.sh
#!bin/bash
nohup /usr/local/kafka_2.12-2.8.0/bin/kafka-server-start.sh /usr/local/kafka_2.12-2.8.0/config/server1.properties > /usr/local/kafka_2.12-2.8.0/logs/kafka/kafka1.log 2>&1 &
nohup /usr/local/kafka_2.12-2.8.0/bin/kafka-server-start.sh /usr/local/kafka_2.12-2.8.0/config/server2.properties > /usr/local/kafka_2.12-2.8.0/logs/kafka/kafka2.log 2>&1 &
nohup /usr/local/kafka_2.12-2.8.0/bin/kafka-server-start.sh /usr/local/kafka_2.12-2.8.0/config/server3.properties > /usr/local/kafka_2.12-2.8.0/logs/kafka/kafka3.log 2>&1 &
内容总结
以上是互联网集市为您收集整理的Linux系统之Kafka+Zookeeper(Kafka自带)单机伪集成部署全部内容,希望文章能够帮你解决Linux系统之Kafka+Zookeeper(Kafka自带)单机伪集成部署所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。