注意：确保有JDK1.8版本及以上

官方文档：https://kafka.apache.org/quickstart

清华镜像下载：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/

首先下载安装包，在linux及Windows都可以使用。

1. Centos 安装部署

1.1 下载

• 将下载好的安装包上传至服务器

• 解压

  tar -zxvf kafka_2.12-2.6.3.tgz
  

1.2 启动zookeeper

• 后台启动zookeeper

  kafka需要依赖ZK，安装包中已经自带了一个ZK，也可以改成指定已运行的ZK。
  如果改成指定的ZK需要修改修改 kafka 安装目录下的 config/server.properties 文件中的zookeeper.connect 。这里使用自带的ZK。

  nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >> zookeeper.nohup &
  

• 检查zookeeper是否启动成功：

  ps -ef|grep zookeeper
  

1.3 启动Kafka

• 修改相关配置

  vim config/server.properties
  

• Broker ID启动以后就不能改了

  broker.id=0
  

• 取消注释，改成本机IP；如果是云服务器记得开启端口；

  # 允许外部端口连接                                            
  listeners=PLAINTEXT://0.0.0.0:9092  
  # 外部代理地址                                                
  advertised.listeners=PLAINTEXT://127.0.0.1:9092
  

• num.partitions后面增加2行。
  发送到不存在topic自动创建。允许永久删除topic。

  num.partitions=1
  auto.create.topics.enable=true
  delete.topic.enable=true
  

• 后台启动kafka（kafka安装目录下）：

  nohup ./bin/kafka-server-start.sh ./config/server.properties >> kafka.nohup &
  

• 日志在tmp目录下，可以自行设置。

1.4 创建Topic

sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

1.5 查看Topic

sh bin/kafka-topics.sh -list -zookeeper localhost:2181

1.6 启动Producer

新窗口，在Kafka的解压目录下。

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

1.7 启动Consumer

开启一个新的窗口，在Kafka的解压目录下。

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

1.8 测试

2. Windows安装部署

2.1 下载解压

目录结构：

2.2 启动zookeepeer

打开CMD，执行如下命令：

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

2.3 启动Kafka

打开CMD，执行如下命令：

bin\windows\kafka-server-start.bat config\server.properties

2.4 创建Topic

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafkaTest

2.4 查看Topic

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

2.5 启动Producer

新开窗口。

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kafkaTest

2.6 启动Consumer

新开窗口。

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafkaTest --from-beginning

2.7 测试