博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Kafka的安装和配置
阅读量:4313 次
发布时间:2019-06-06

本文共 2044 字,大约阅读时间需要 6 分钟。

安装Kafka的方式,分别为:单节点单Broker部署、单节点多Broker部署、集群部署(多节点多Broker)。实际生产环境中使用的是第三种方式,以集群的方式来部署Kafka

Kafka强依赖ZK,如果想要使用Kafka,就必须安装ZK,Kafka中的消费偏置信息、kafka集群、topic信息会被存储在ZK中。有人可能会说我在使用Kafka的时候就没有安装ZK,那是因为Kafka内置了一个ZK,一般我们不使用它

 

安装JDK(kafka依赖jdk)

 

一、Kafka 单节点部署

Kafka中单节点部署又分为两种,一种为单节点单Broker部署,一种为单节点多Broker部署。因为是单节点的Kafka,所以在安装ZK时也只需要单节点即可

1、cd /usr/local/software  # 这里自定安装目录

2、wget http://www.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz  # 下载kafka

3、tar -xzvf kafka_2.11-0.8.2.1.tgz  # 解压

4、mv kafka_2.11-0.8.2.1 /usr/local/kafka  # 移动到安装目录

5、mkdir /usr/local/kafka/log/kafka  # 如果提示没有此目录则手动创建

6、cd /usr/local/kafka/config # 进入配置目录

7、vim server.properties 

8、找到broker.id=0这一行,后面添加下面的内容

port=9092 # 端口号

host.name=192.168.5.56  # 服务器IP地址,修改为自己的服务器IP

log.dirs=/usr/local/kafka/log/kafka  # 日志存放路径,上面创建的目录

zookeeper.connect=localhost:2181  # zookeeper地址和端口,单机配置部署,localhost:2181

9、mkdir /usr/local/kafka/zookeeper  # 创建zookeeper目录

10、mkdir /usr/local/kafka/log/zookeeper  # 创建zookeeper日志目录

11、cd /usr/local/kafka/config   # 进入配置目录

12、vi zookeeper.properties #编辑修改相应的参数

dataDir=/usr/local/kafka/zookeeper #zookeeper数据目录

dataLogDir=/usr/local/kafka/log/zookeeper #zookeeper日志目录

clientPort=2181

maxClientCnxns=100

tickTime=2000

initLimit=10

syncLimit=5

13、cd /usr/local/kafka  # 创建启动脚本

14、vi kafkastart.sh  # 这是新建一个脚本

#!/bin/sh

#启动zookeeper

/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &

#等3秒后执行

sleep 3

#启动kafka

/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

15、vi kafkastop.sh # 创建关闭脚本

#!/bin/sh

#关闭zookeeper

/usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties &

sleep 3 #等3秒后执行

#关闭kafka

/usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties &

 16、添加启动和关闭脚本的权限

chmod +x kafkastart.sh

chmod +x kafkastop.sh

17、vi /etc/rc.d/rc.local  # 这个文件就在这个目录下有,设置脚本开机自动执行

sh /usr/local/kafka/kafkastart.sh #启动kafka

sh /usr/local/kafka/kafkastop.sh #关闭kafka

18、jps -lm  # 查看kafka

 

转载于:https://www.cnblogs.com/shizhengquan/p/10956403.html

你可能感兴趣的文章
Python-循环
查看>>
(转)最大子序列和问题 看着貌似不错
查看>>
thinkphp3.2 链接数据库测试
查看>>
项目的上线流程是怎样的?
查看>>
Linux通配符
查看>>
ES6 Iterator
查看>>
Apache2.4开启GZIP功能
查看>>
远程桌面关闭重启电脑的方法
查看>>
第三章 熟悉常用的HDFS操作
查看>>
filter:expression(document.execCommand("BackgroundImageCache",false,true) 转
查看>>
Java - 30 Java 网络编程
查看>>
shiro中的filterChainDefinitions
查看>>
瑞柏匡丞教你如何和程序员一起愉快的玩耍
查看>>
【单调队列】Vijos P1771 瑞士轮 (NOIP2011普及组第三题)
查看>>
【模拟】NEERC15 E Easy Problemset (2015-2016 ACM-ICPC)(Codeforces GYM 100851)
查看>>
JavaBean and PreparedStatement Usage
查看>>
经典冒泡排序
查看>>
HDU1312:Red and Black(DFS)
查看>>
es6 async与await实战
查看>>
北京行——xml解析之SAX
查看>>