一、单机安装

1、上传压缩文件到服务器、解压

tar -zxvf kafka_2.13-3.3.2.tgz -C /usr/local #解压到 usr/local目录下

进入解压目录下

更名kafka

mv kafka_2.13-3.3.2/ kafka-3.3.2

2、配置环境变量

 vim /etc/profile

export KAFKA_HOME=/usr/local/kafka-3.3.2

export PATH=$PATH:$KAFKA_HOME/bin

刷新环境变量

source /etc/profile

3、查看相关配置文件

4、启动zookeeper，kafka内置了zookeeper

bin/zookeeper-server-start.sh -daemon config/ zookeeper.properties

 

zookeeper没启动，原因：未安装openjdk-devel，未配置JDK环境变量、未安装Zookeeper

 

yum install -y java-1.8.0-openjdk.x86_64     # 安装java-1.8    -y表示安装过程中全部选择yes

yum install java-1.8.0-openjdk-devel.x86_64   #安装openjdk-devel

 

jvm目录下内容：

java                                             jre
java-1.8.0                                       jre-1.8.0
java-1.8.0-openjdk                               jre-1.8.0-openjdk
java-1.8.0-openjdk-1.8.0.362.b08-1.el7_9.x86_64  jre-1.8.0-openjdk-1.8.0.362.b08-1.el7_9.x86_64
java-openjdk

5、安装好重新启动zookeeper

bin/zookeeper-server-start.sh -daemon config/ zookeeper.properties

成功启动zookeeper

6、启动kafka

相关配置信息

查看或修改kafka的配置信息

vim config/server.properties

启动kafka命令

bin/kafka-server-start.sh -daemon config/server.properties

7、进入zookeeper的客户端

 bin/zookeeper-shell.sh localhost:2181

 

二、单机版测试

1、创建主题

kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytest

 

2、查看创建的主题

kafka-topics.sh --list --bootstrap-server localhost:9092

3、创建生产者

以控制台输入信息

kafka-console-producer.sh --broker-list localhost:9092 --topic mytest

4、创建控制台消费者

kafka-console-consumer.sh --bootstrap-server  localhost:9092 --from-beginning --topic mytest

消费信息，若不能及时消费生产的信息，则需要在生产者控制台中输入

kafka is a message queue

 之后生产者产生的信息 消费者都能及时消费了

注：在实际中，一般使用的是集群操作，单机的kafka起不到什么作用。