《Kafka命令行操作》

---

title: 《Kafka命令行操作》
date: 2022-6-7 21:20:41
description: Spark (HA) Spark (Yarn)

阅读全文

**

1、cd /export/server/kafka/bin目录下的命令行工具

kafka-configs.sh	用于配置管理
kafka-console-consumer.sh	用于消费消息
kafka-console-producer.sh	用于生产消息
kafka-consumer-perf-test.sh	用于测试消费性能
kafka-topics.sh	用于管理主题
kafka-dump-log.sh	用于查看日志内容
kafka-server-stop.sh	用于关闭kafka服务
kafka-preferred-replica-election.sh	用于优先副本的选举
kafka-server-start.sh	用于启动kafka服务
kafka-producer-perf-test.sh	用于测试生产性能
kafka-reassign-partitions.sh	用于分区重分配

2、查看当前可用topic（应该什么也没有）

3、创建topic，检查是否创建成功

4、手动指定副本的存储位置，进入cd /export/data/kafka-logs路径下查看分区的分布

5、进入到zookeeper client，查看目录、controller、controller_epoch

6、删除topic，检查是否删除成功

7、查看topic详情

8、增加分区数，查看topic详情

9、修改参数

10、生产者写入数据、消费者拉取数据


**

---