一        安装配置

        学习的是kafka3.0版本，对应的zookeeper版本是3.7.x；kafka3.0版本可以不依赖于外部搭建zookeeper，因为自带有zookeeper。

        注意：如果启动过程中有报clusterId的错误的，推荐多试试第一种；

1. 将正确的clusterid复制到meta.properties中进行替换，然后重新启动这个对应的kafka服务；(正确的clusterId是指我们之前启动成功过的，并且创建过topic且消费过消息的，然后我们将这个id复制到不同于这个ID的meta.properties中，然后关闭被复制了的服务，然后逐个启动，可能和先后启动的顺序有关，挂了就换顺序启动，这个方式可以保证我们关闭所有的服务后，重新启动zookeeper和kafka之后，还能获取到之前创建的topic)；
2. 将对应的meta.properties文件删除，然后重启；
3. 可以将datas文件（server配置设置的保存数据的文件夹）删除；会丢失数据；

1.1        zookeeper安装

1.1.1        单机安装

1.1.1.1        安装包下载地址：

Apache Kafka

1.1.1.2        解压安装

tar -zxvf 安装包 -C 安装到的对应路径

1.1.1.3        配置修改

        复制conf/zoo_sample.cfg为conf/zoo.cfg，并根据需要编辑配置文件，例如设置dataDir和clientPort。

        命令：cp zoo_sample.cfg zoo.cfg

然后给添加两行命令，单机简易版就不做其它修改了

dataDir=/app/soft/zookeeper-3.4.10/data
dataLogDir=/app/soft/zookeeper-3.4.10/log

1.1.1.4        服务启动

进入bin目录
# 启动Zookeeper服务器
bin/zkServer.sh start
 
# 检查Zookeeper状态
bin/zkServer.sh status


zkCli.sh [-server ip:port]


create /zk "123"
get /zk

1.2        kafka安装

1.2.1        单节点安装

        并不需要再单独启动上面的zookeeper服务，这个kafka3.0版本本就自带zookeper；但是必须要启动一个zookeeper，启动jar包自带的，或者是上面搭建的单独的zookeeper；

1.2.1.1        安装包下载

Apache Kafka

1.2.1.2        解压安装

tar -zxvf 安装包名 -C 要解压到的路径

1.2.1.3        配置修改

1:修改conf下zookeeper配置文件
更改日志数据存储文件


2:修改server配置文件
broker.id=1
log.dirs=/Applications/soft/kafka/kafkaZookeeper/single/datas

# 指定在zookeeper上的位置，方便管理，查询节点数据
zookeeper.connect=localhost:2181/singlZookeeperKafka

1.2.1.4        服务启动

# 启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

# 以后台的方式启动，若是启动失败（jps查看是否有kafka进程），可以将daemon去掉，然后查看启动日志
bin/kafka-server-start.sh -daemon config/server.properties

# 创建topic主题进行验证
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

# 发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

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

# 查询已创建的主题列表
bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092

# 查询主题信息
bin/kafka-topics.sh --describe --bootstrap-server 127.0.0.1:9092 --topic topic1

1.2.2        伪集群安装（单机不同端口）

1.2.2.1        安装包下载

Apache Kafka

1.2.2.2        解压安装

创建三个kafka文件夹，将安装包解压到这三个目录下

tar -xzvf 安装包名 -C 要解压到的路径

1.2.2.3        配置修改

分别修改这三个文件夹中的配置，都需要占用不用的端口

1:修改conf下zookeeper配置文件（zookeeper.properties）
更改日志数据存储文件及端口
dataDir=/Applications/soft/kafka/kafkaZookeeper/colony/kafka1/zookeeperDatas
# the port at which the clients will connect
clientPort=2183
（剩下的两个文件采用其他端口）


2:修改server配置文件（server.properties），broker.id必须唯一；
broker.id=1
log.dirs=/Applications/soft/kafka/kafkaZookeeper/colony/kafka1/datas

# 监听使用不同的端口
listeners=PLAINTEXT://127.0.0.1:9093


# 指定在zookeeper上的位置，方便管理，查询节点数据（集群的没加，未解决）
# 指定三台服务器各自使用的zookeeper地址
zookeeper.connect=localhost:2183,localhost:2184,localhost:2185

1.2.2.4        服务启动

# 启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

# 以后台的方式启动，若是启动失败（jps查看是否有kafka进程），可以将daemon去掉，然后查看启动日志
# 集群的就不加了，方便查询错误信息
bin/kafka-server-start.sh config/server.properties


# 查询topic信息，可以加--topic topicName；查询指定topic信息
bin/kafka-topics.sh --bootstrap-server localhost:9093,localhost:9094,localhost:9095 --describe

# 查询所有的topic列表数据
bin/kafka-topics.sh --bootstrap-server localhost:9093,localhost:9094,localhost:9095 --list

# 创建一个主题，算是验证集群是否启动成功
bin/kafka-topics.sh --bootstrap-server localhost:9093,localhost:9094,localhost:9095 --create --partitions 3 --replication-factor 3 --topic clonytopic666