Kafka案例2-kafka命令行的使用

作者：黑客灵魂 | 2024-07-06 18:46:27

踩

参数	描述
–bootstrap-server<<String: server to connect to>	连接的kafka broker主机名称和端口号
–list	查看所有的主题
–create	创建主题
–partitions <Integer: # of partitions>	设置分区数
–replication-factor <Integer:replication factor>	设置分区的副本
–topic <String: topic>	操作的topic名称
–delete	删除主题
–alter	修改主题
–list	查看所有主题
–describe	查看主题详细描述

kafka命令行操作
1、主题(Topic)命令行的操作
(1)查看topic的命令参数

bin/kafka-topics.sh
1

(2)查看当前服务器中所有的topic

bin/kafka-topics.sh --bootstrap-server master:9092 --list
1

(3)创建名为firstkafka的topic

bin/kafka-topics.sh --bootstrap-server master:9092 --create --partitions 1 --replication-factor 3 --topic firstkafka
1

(4)查看firstkafka主题的详情

bin/kafka-topics.sh --bootstrap-server master:9092 --describe --topic firstkafka
1

(5)修改分区数（注意：分区数只能增加，不能减少）

bin/kafka-topics.sh --bootstrap-server master:9092 --alter --topic firstkafka --partitions 3
1

(6)再次查看firstkafka主题的详情

bin/kafka-topics.sh --bootstrap-server master:9092 --describe --topic firstkafka
1

(7)删除topic

bin/kafka-topics.sh --bootstrap-server master:9092 --delete --topic firstkafka
1

先开消费者，再开生产者。

2.生产者命令行操作

(1)查看操作生产者的命令参数

bin/kafka-console-producer.sh
1

(2)发送消息

bin/kafka-console-producer.sh --broker-list master:9092 --topic firstkafka
>hello world
>bigdata
1
2
3

3.消费者命令行操作

(1)查看操作消费者的命令参数

bin/kafka-console-consumer.sh
1

(2)消费消息

消费firstkafka主题中的数据

bin/kafka-console-consumer.sh --bootstrap-server master:9092 --topic firstkafka
1

把主题中所有的数据都读出来（包括历史数据）

bin/kafka-console-consumer.sh --bootstrap-server master:9092 --from-beginning --topic firstkafka
1

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/黑客灵魂/article/detail/793700