主题命令行操作
- 查看操作主题命令参数
[kunfire@hadoop102 kafka]$ bin/kafka-topics.sh
参数 |
描述 |
--bootstrap-server <String: server toconnect to> |
连接的Kafka Broker主机名称和端口号。 |
--topic <String: topic> |
操作的topic名称。 |
--create |
创建主题。 |
--delete |
删除主题。 |
--alter |
修改主题。 |
--list |
查看所有主题。 |
--describe |
查看主题详细描述。 |
--partitions <Integer: # of partitions> |
设置分区数。 |
--replication-factor<Integer: replication factor> |
设置分区副本。 |
--config <String: name=value> |
更新系统默认的配置。 |
- 查看当前服务器中的所有topic
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --list
- 创建first topic
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --create--partitions1--replication-factor3--topic first 选项说明： --topic 定义topic名 --replication-factor 定义副本数 --partitions 定义分区数
- 查看first主题的详情
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe--topic first
- 修改分区数（注意：分区数只能增加，不能减少）
$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --alter--topic first --partitions3
- 再次查看first主题的详情
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe--topic first
- 删除topic
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --delete--topic first
生产者命令行操作
- 查看操作生产者命令参数
bin/kafka-console-producer.sh
参数 |
描述 |
--bootstrap-server <String: server toconnect to> |
连接的Kafka Broker主机名称和端口号。 |
--topic <String: topic> |
操作的topic名称。 |
- 发送消息
bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first >hello world >atguigu atguigu
消费者命令行操作
- 查看操作消费者命令参数
bin/kafka-console-consumer.sh
参数 |
描述 |
--bootstrap-server <String: server toconnect to> |
连接的Kafka Broker主机名称和端口号。 |
--topic <String: topic> |
操作的topic名称。 |
--from-beginning |
从头开始消费。 |
--group <String: consumer group id> |
指定消费者组名称。 |
- 消费消息
#消费first主题中的数据bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first #把主题中所有的数据都读取出来（包括历史数据）bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from-beginning--topic first
