kafka 安装包下载
- jdk安装包下载
- zookeeper安装包下载
- kafka安装包下载
- 上传安装包到 你要安装的目录下（/usr）
安装java环境
1-1.解压java安装包
tar -zxvf /usr/jdk-8u231-linux-x64.tar.gz
1-2.配置环境变量
vi /etc/profile
#编辑profile文件将下面java环境变量配置到文档末尾中
#set java environment
JAVA_HOME=/usr/jdk1.8.0_231
PATH=$PATH:$JAVA_HOME/bin
CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export JAVA_HOME CLASSPATH PATH
1-3.让配置文件生效
source /etc/profile
1-4.校验java是否安装成功
java -version
#若显示已下内容则安装成功
[root@root usr]# java -version
java version "1.8.0_231"
Java(TM) SE Runtime Environment (build 1.8.0_231-b11)
Java HotSpot(TM) 64-Bit Server VM (build 25.231-b11, mixed mode)
安装zookeeper
2-1.解压zookeeper安装包
tar -zxvf /usr/zookeeper-3.6.1-bin.tar.gz
2-2.更改配置文件名称（conf目录下提供了配置的样例zoo_sample.cfg，要将zk运行起来，需要将其名称修改为zoo.cfg）
cd /usr/apache-zookeeper-3.6.1-bin/conf/
2-3.启动zookeeper
[root@root /]# cd /usr/apache-zookeeper-3.6.1-bin/bin/
##启动zookeeper
[root@root bin]# ./zkServer.sh start zoo.cfg
##查看zookeeper状态
[root@root bin]# ./zkServer.sh status zoo.cfg
ZooKeeper JMX enabled by default
Using config: /usr/apache-zookeeper-3.6.1-bin/bin/../conf/zoo.cfg
Client port found: 2181\. Client address: localhost.
Mode: standalone
安装kafka
3-1.解压kafka安装包
tar -zxvf /usr/kafka_2.12-2.5.0.tgz
3-2.配置 kafka配置文件
[root@root /]# cd /usr/kafka_2.12-2.5.0/
oot@root kafka_2.12-2.5.0]# ls
bin config libs LICENSE logs NOTICE site-docs
[root@root kafka_2.12-2.5.0]# cd config/
[root@root config]# ls
1 connect-console-source.properties connect-file-sink.properties connect-log4j.properties connect-standalone.properties log4j.properties server.properties trogdor.conf
connect-console-sink.properties connect-distributed.properties connect-file-source.properties connect-mirror-maker.properties consumer.properties producer.properties tools-log4j.properties zookeeper.properties
[root@root config]# vim server.propertie
3-3.kafka需要修改的配置
| 配置参数 | 解释 |
|---|---|
| broker.id=0 | 这个主要配置集群的时候设定不同borker 单机这里不用管 |
| listeners=PLAINTEXT://ip 或者 your.host.name:9092 | 注意这里 配置你当前hostName:9092；hostname是你主机的名称（可以直接配置localhost） 9092是kafka的端口号 |
| advertised.listeners=PLAINTEXT://外网ip:9092 | 如果你是在阿里云等服务器上部署的，就需要把kafka的访问地址配置在这里，将上面的配置注释掉，并且访问你的外网ip |
| log.dirs=/usr/kafka-logs | 配置kafka日志的输出地址，根据自己的需要配置，我是配置在了/usr下面 |
| zookeeper.connect=ip 或者 your.host.name:2181 | 配置kafka连接的zookeeper地址 2181是zookeeper的默认端口号 |
3-4.kafka启动及查看命令
##进到kafka bin目录下
[root@root bin]# cd /usr/kafka_2.12-2.5.0/bin/
##启动kafka -daemon -- 后台启动
[root@root bin]# ./kafka-server-start.sh -daemon ../config/server.properties
##查看topic
[root@root bin]# ./kafka-topics.sh --list --zookeeper localhost:2181
__consumer_offsets
__transaction_state
topic01
topic02
topic03
##创建生产者
[root@root bin]# ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic01
##创建消费者
[root@root bin]# ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic topic01
##创建topic
[root@root bin]# ./kafka-topics.sh --create --zookeeper localhost:2181 -replication-factor 1 --partitions 1 --topic fufu
