阅读量:0
| 参数 | 描述 |
|---|---|
| –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 --partitions 1 --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 --partitions 3 (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 