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