前置条件：JDK需要安装在Linux服务器中。

一、安装kafka。

手动下载 下载地址：http://kafka.apache.org/downloads。

2.80后，Kafka内置zookeeper，因此，无需重复安装。

二. 解压Kafka。

命令：tar -xzvf kafka_2.13-3.6.2.tgz。

三. 修改文件。

1. 进入config目录：cd config。
2. 修改server.properties：vim server.properties。
3. 找到以下两行󿀌删除前面的 #。
   在advertised中.在listeners上填写外网id地址。

broker.id： 在集群中申报kafka服务器的唯一ID，需要配置为integer，集群中每个kafka服务器的id应该是唯一的，我们可以在这里使用默认配置。
listeners：说明kafka服务器需要监控的端口号，如果在本机上运行虚拟机，则无需配置本项，默认使用localhost地址，如果在远程服务器上运行，则必须配置，例如：listeners=PLAINTEXT://192.168.180.128:9092。并确保服务器9092端口能够访问。
zookeeper.connect：声明zookeeper与kafka连接的地址󿀌zookeper地址࿰需要配置c;因为这次使用的是自带zookeeper࿰的kafka高版本c;使用默认配置即可。

四. 检查防火墙是否打开#xff0c;端口是否开放。

启动防火墙：systemctl start firewalld。
检查防火墙状态：systemctl status firewalld。
防火墙：systemctl disable firewalld。
停止防火墙：systemctl stop firewalld。

查看开放端口：firewall-cmd --list-port。
添加开放端口：firewall-cmd --zone=public --add-port=80/tcp --premanent （–premanent永久生效，没有这个参数󿀌重启后失效）
重新载入规则：firewall-cmd --reload。

五. 启动zookeeper。

由于高版kafka内置zookeeper，因此无需单独安装和修改相关配置文件信息，直接启动即可。

进入bin目录，启动zookeeper服务。
命令： ./zookeeper-server-start.sh -daemon ../config/zookeeper.properties。

• 查看zookeeper服务是否通过日志启动。

• 还可以通过命令检查服务是否启动。
  命令：jps。
  

六. 启动Kafka。

命令： ./kafka-server-start.sh -daemon ../config/server.properties。，您还可以使用jps查看服务启动状态。

此时，zookeper和kafka服务已经启动c;接下来可以创建topic。

七. 创建topic。

下列命令均在kafkabin目录下执行。
新增topic。
命令： ./kafka-topics.sh --create --bootstrap-server X.X.X.X:9092 --replication-factor 1 --partitions 1 --topic test。

test是topic，回到Creates topic "your topic"这意味着创造的成功。
选项说明：
–topic 定义topic名。
–replication-factor 定义副本数。
–partitions 定义分区数。

查询topic:。
命令：./kafka-topics.sh --list --bootstrap-server X.X.X.X:9092。

删除topic。
命令： ./kafka-topics.sh --bootstrap-server X.X.X.X:9092 --delete -topic test。

模拟测试生产/消费信息。
在终端上创建生产者。
命令：./kafka-console-producer.sh --bootstrap-server X.X.X.X:9092 --topic test。

在另一个终端上创建消费者。
命令：./kafka-console-consumer.sh --bootstrap-server X.X.X.X:9092 --topic test。

左侧消费消息󿀌右侧生产新闻。

简单测试kafka在Linux下的成功生产消费信息;

八。简单命令总结：
创建topic：./kafka-topics.sh --create --bootstrap-server X.X.X.X:9092 --replication-factor 1 --partitions 1 --topic test。
删除topic：./kafka-topics.sh --bootstrap-server X.X.X.X:9092 --delete -topic test。
查询topic：./kafka-topics.sh --list --bootstrap-server X.X.X.X:9092。
指定消费者组：./kafka-console-consumer.sh --bootstrap-server X.X.X.X:9092 --group em --topic test。
“em” 是你想指定的消费者群体。

查询消费者组信息：