kafka_2.13-3.2.0.tgz配置安装

1、下载kafka

下载 地址：https://kafka.apache.org/downloads

命令：wget https://dlcdn.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz

2、解压配置 tar -xzvf kafka_2.13-3.2.0.tgz

3、常用命令行工具

Kafka 的命令行工具在 Kafka 包的/bin目录下，主要包括服务和集群管理脚本，配置脚本，信息查看脚本，Topic 脚本，客户端脚本等。

kafka-configs.sh：配置管理脚本 kafka-console-consumer.sh：kafka 消费者控制台 kafka-console-producer.sh：kafka 生产者控制台 kafka-consumer-groups.sh：kafka 消费者组相关信息 kafka-delete-records.sh：删除低水位的日志文件 kafka-log-dirs.sh：kafka 消息日志目录信息 kafka-mirror-maker.sh：不同数据中心 kafka 集群复制工具 kafka-preferred-replica-election.sh：触发 preferred replica 选举 kafka-producer-perf-test.sh：kafka 生产者性能测试脚本 kafka-reassign-partitions.sh：分区重分配脚本 kafka-replica-verification.sh：复制进度验证脚本 kafka-server-start.sh：启动 kafka 服务 kafka-server-stop.sh：停止 kafka 服务 kafka-topics.sh：topic 管理脚本 kafka-verifiable-consumer.sh：可检验的 kafka 消费者 kafka-verifiable-producer.sh：可检验的 kafka 生产者 zookeeper-server-start.sh：启动 zk 服务 zookeeper-server-stop.sh：停止 zk 服务 zookeeper-shell.sh：zk 客户端

4、启动kafka [root@tset bin]# ./kafka-server-start.sh -daemon ../config/server.properties

5、创建topic

./kafka-topics.sh --bootstrap-server 192.168.0.111:9092 --create --replication-factor 1 --partitions 1 --topic test

6、测试kafka

[root@test bin]# ./kafka-console-producer.sh --broker-list 192.168.0.111:9092 --topic test

7、接收消息 /kafka_2.13-3.2.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.111:9092 --topic test --from-beginning

8、查看topics [root@test kafka_2.13-3.2.0]# ./bin/kafka-topics.sh --bootstrap-server 192.168.0.111:9092 --list

__consumer_offsets binlog test

9、查看消费情况 [root@test bin]# /kafka_2.13-3.2.0/bin/kafka-consumer-groups.sh --describe --bootstrap-server 192.168.0.111:9092 --group group_1

GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID group_1 test 0 463 463 0 rdkafka-364dcbd9-c38e-4f25-bc89-8e7788c788fc /192.168.0.58 rdkafka