Kafka - Topic命令 & 命令行操作_--topic

目录

零、前置

一、Topic命令

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

创建 first topic

查看 first 主题的详情

修改分区数量

删除 topic

二、生产者命令行操作

发送消息

三、消费者命令行操作

消费 first 主题中的数据

---

零、前置

Kafka集群的搭建：Kafka + Zookeeper + Hadoop 集群配置

---

一、Topic命令

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

注意位置：

cd /opt/module/kafka

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

因为咱们还没有创建主题，所以这里是空着的。

创建 first topic

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

选项说明：

--topic 定义 topic 名

--replication-factor 定义副本数

--partitions 定义分区数

查看 first 主题的详情

bin/kafka-topics.sh --bootstrap-server test1:9092 --describe --topic first

修改分区数量

注：分区数只能增加不能减少

bin/kafka-topics.sh --bootstrap-server test1:9092 --alter --topic first --partitions 3

减少时则会报错：

删除 topic

bin/kafka-topics.sh --bootstrap-server test1:9092 --delete --topic first

---

二、生产者命令行操作

发送消息

bin/kafka-console-producer.sh --bootstrap-server test1:9092 --topic first

---

三、消费者命令行操作

消费 first 主题中的数据

bin/kafka-console-consumer.sh --bootstrap-server test1:9092 --topic first

 可以看到这里消费不到咱们之前发的 hello world ，如果想要查看之间生产的数据需要加上 --from-beginning 。

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

加上重新进入后即可消费到之前的数据。

---