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

参数描述–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

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

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

(3)创建名为firstkafka的topic

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

(4)查看firstkafka主题的详情

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

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

bin/kafka-topics.sh --bootstrap-server master:9092 --alter--topic firstkafka --partitions3

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

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

(7)删除topic

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

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

2.生产者命令行操作

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

bin/kafka-console-producer.sh

(2)发送消息

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

3.消费者命令行操作

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

bin/kafka-console-consumer.sh

(2)消费消息

消费firstkafka主题中的数据

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

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

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