Kafka - Topic命令 & 命令行操作

零、前置

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

一、Topic命令

参数功能--bootstrap-server连接的 Kafka Broker 主机名称和端口号--topic操作的 topic 名称--create创建主题--delete删除主题--alter修改主题--list查看所有主题--describe查看主题详细描述--partitions设置分区数--replication-factor设置分区副本--config更新系统默认的配置

查看当前服务器中的所有 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

二、生产者命令行操作

参数描述--bootstrap-server连接的 Kafka Broker 主机名称和端口号--topic操作的 topic 名称

发送消息

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

三、消费者命令行操作

参数描述--bootstrap-server连接的 Kafka Broker 主机名称和端口号--topic操作的 topic 名称--from-beginning从头开始消费--group指定消费者组名称

消费 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

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