kafka的安装

一、安装zookeeper

安装kafka必须先安装zookeeper,由于kafka自带有zookeeper,可以选择性安装第三方的zookeeper,建议安装第三方的zookeeper

zookeeper的搭建和简单的使用

二、下载并解压kafka安装包到三台服务器上

三、分别修改三台服务器配置文件

1.修改server.properties

## broker的全局唯一编号,不能重复
broker.id=0
## 服务器需要监听的端口号
listeners=PLAINTEXT://master: 
## 注册到zookeeper的IP和端口
advertised.listeners=PLAINTEXT://master:9092
## 存储消息的目录
log.dirs=/opt/apply/kafka_2.12-2.5.1/kafka-logs
## 连接的zookeeper
zookeeper.connect=master:2181,slaver1:2181,slaver1:2181
说明
broker.id 三个节点分别设置为 0、1、2
listeners PLAINTEXT://slaver1:9092,根据当前机器的IP设置
advertised.listeners PLAINTEXT://slaver1:9092,根据当前机器的IP设置

2.修改producer.properties

## 指定kafka节点列表,用于获取metadata,不必配置全部
bootstrap.servers=master:9092,slaver1:9092,slaver2:9092

3.修改consumer.properties

## 指定kafka节点列表,用于获取metadata,不必配置全部
bootstrap.servers=master:9092,slaver1:9092,slaver2:9092

4.如果使用kafka自带的zookeeper(安装第三方zookeeper的请跳过这一步)

请修改配置文件下的zookeeper.properties文件,修改方法和上面第三方zookeeper配置相同(参看上述链接博客)

四、启动&停止集群命令

1.启动zookeeper

## 先启动好zookeeper
## 如果使用第三方的zookeeper使用下面这条命令
zkServer.sh start
## 如果使用kafka自带的zookeeper,进入kafka的bin目录里执行一下命令
./zookeeper-server-start.sh ../config/zookeeper.properties & 

2.启动kafka

## 启动kafka
cd /opt/apply/kafka_2.12-2.5.1/bin
## 前台运行
./kafka-server-start.sh ../config/server.properties
## 后台运行
./kafka-server-start.sh -daemon ../config/server.properties &

3.停止kafka

## 停止kafka
cd /opt/kafka/kafka_2.12-2.5.0/bin
./kafka-server-stop.sh  

声明:该文章系转载,转载该文章的目的在于更广泛的传递信息,并不代表本网站赞同其观点,文章内容仅供参考。

本站是一个个人学习和交流平台,网站上部分文章为网站管理员和网友从相关媒体转载而来,并不用于任何商业目的,内容为作者个人观点, 并不代表本网站赞同其观点和对其真实性负责。

我们已经尽可能的对作者和来源进行了通告,但是可能由于能力有限或疏忽,导致作者和来源有误,亦可能您并不期望您的作品在我们的网站上发布。我们为这些问题向您致歉,如果您在我站上发现此类问题,请及时联系我们,我们将根据您的要求,立即更正或者删除有关内容。本站拥有对此声明的最终解释权。