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
评论