本文介绍了linux下kafka的安装与部署，其中zookeeper采用kafka自带的

1. 下载

  • 登陆kafka官网：https://kafka.apache.org/downloads
  • 利用下载地址进行下载 
    wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz

    kafka官网.png

下载地址.png

2. 解压

tar -zxvf kafka_2.13-3.1.0.tgz

kafka解压.png

3. 修改server.properties文件

  • 进入kafka目录
  • 进入config目录
  • 修改kafka配置文件server.properties 配置文件主要修改了日志的存放地址 
    log.dirs=/kafka/single/kafka_2.13-3.1.0/data/log
port=9092
host.name=localhost

4. 修改zookeeper.properties文件

dataDir=/kafka/single/kafka_2.13-3.1.0/zookeeper/data/dataDir
dataLogDir=/kafka/single/kafka_2.13-3.1.0/zookeeper/data/dataLogDir
maxClientCnxns=100
tickTime=2000
initLimit=10

5. 启动kafka

5.1 启动zookeeper

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

5.2 启动kafka

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

5.3 启动kafka-producer

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic keweizhou_1

5.4 启动kafka-consumer

./bin/kafka-console-consumer.sh  --bootstrap-server localhost:9092 --topickeweizhou_1 --from-beginning