Kafka常用命令

最新推荐文章于 2025-03-13 22:52:50 发布

菜鸟逆袭记

最新推荐文章于 2025-03-13 22:52:50 发布

阅读量239

点赞数

分类专栏： kafka核心技术与实战文章标签：后端 kafka

本文链接：https://blog.csdn.net/qq_36748414/article/details/104871389

版权

1 篇文章

订阅专栏

本文档介绍了Kafka的基本操作，包括如何创建topic、查看topic信息、发送和消费消息、查看消费者详情以及删除topic。每个步骤都详细列出了相应的命令参数，如创建topic时设置分区数和副本数，以及消费消息时从头开始读取的选项。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

1.创建topic

bin/kafka-topics.sh --create --zookeeper hadoop1001:2181 --partitions 2 --replication-factor 2 --topic first

--create: 表明创建topic

--zookeeper: 连接zookeeper地址

--partitions: 分区数

--replication-factor: 副本数

--topic: topic名称

bin/kafka-topics.sh --list --zookeeper hadoop1001:2181

bin/kafka-console-producer.sh --broker-list hadoop1001:9092 --topic first

--broker-list: 发送到指定broker

--topic: 发送到指定topic

bin/kafka-console-consumer.sh --bootstrap-server hadoop1001:9092 --from-beginning --topic first

--bootstrap-server: 消费的kafka服务

--from-beginning: 读取指定topic所有数据，offset从头开始

--topic: 指定消费的topic

--consumer.config: 指定消费者配置文件

bin/kafka-topics.sh --zookeeper hadoop1001:2181 --describe --topic first

--describe: 详细信息

bin/kafka-topics.sh --zookeeper hadoop1001:2181 --delete --topic first

表示当前topic被标记删除，可通过修改server.propertites的delete.topic.enable=true物理删除