下载安装

确保环境后访问官网，下载所需要的安装包，需要注意的是kafka从设计上就是依赖zookeeper的，但是最新版本中已经集成了zookeeper，同时需要注意zookeeper启动需要java环境。
image.png
下载完成后，上传至服务器并解压，参考命令如下：

  1. # 上传文件包
  2. rz kafka_2.13-2.6.0.tgz
  3. # 解压缩
  4. tar -zxvf kafka_2.13-2.6.0.tgz
  5. # 重命名
  6. mv kafka_2.13-2.6.0 kafka2.13

调整配置文件

修改kafka的配置文件：

  1. # 进入配置文件夹
  2. cd kafka2.13/config
  3. # 修改配置文件
  4. vim server.properties

常见需要自定义的配置项如下：

  1. # 日志文件路径
  2. log.dirs=/tmp/kafka
  3. # 连接的zookeeper的地址
  4. zookeeper.connect=127.0.0.1:2181
  5. # 如果不是本机使用需要将此处调整为部署kafka的服务器地址，否则解析IP时会出现异常情况
  6. listeners=PLAINTEXT://192.168.206.101:9092
  7. advertised.listeners=PLAINTEXT://192.168.206.101:9092

配置系统环境变量

修改环境变量：

  1. vim /etc/profile

环境变量中需要增加内容：

  1. # kafka文件夹路径
  2. KAFKA_HOME=/work/kafka3.12
  3. # 在原本的path后增加kafka相关的配置
  4. PATH=$PATH:$KAFKA_HOME/bin
  5. # export
  6. export KAFKA_HOME PATH

然后需要使环境变量生效：

  1. source /etc/profile

常用命令

  1. # 启动zookeeper命令
  2. /work/kafka2.13/bin/zookeeper-server-start.sh /work/kafka2.13/config/zookeeper.properties &
  3. # 停止zookeeper命令
  4. /work/kafka2.13/bin/zookeeper-server-stop.sh
  5. # 启动kafka命令（需要先启动zookeeper）
  6. /work/kafka2.13/bin/kafka-server-start.sh /work/kafka2.13/config/server.properties &
  7. # 停止kafka命令
  8. /work/kafka2.13/bin/kafka-server-stop.sh
  9. # 查看topic列表
  10. /work/kafka2.13/bin/kafka-topics.sh --list --zookeeper localhost:2181
  11. # 通过命令行给指定topic发送消息，需要自行更换IP地址及topic名称
  12. /work/kafka2.13/bin/kafka-console-producer.sh --broker-list 192.168.206.101:9092 --topic event
  13. # 通过命令行消费指定topic消息，需要自行更换IP地址及topic名称
  14. /work/kafka2.13/bin/kafka-console-consumer.sh --bootstrap-server 192.168.206.101:9092 --topic event --from-beginning

相关学习资料

Kafka学习(三)：Kafka的内部机制深入(持久化，分布式，通讯协议)