开发者社区> 问答> 正文

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

展开
收起
cjpler 2022-07-30 11:42:08 893 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载