目录

一、创建主题

二、查看主题

三、修改分区数

四、删除主题

五、生产数据

六、创建消费组

---

一、创建主题

--- kafka-topics.sh

---bootstrap-server 指定连接的kafka服务

- --create 创建主题

- --partitions 指定分区数 默认一个

- --replication-factor 指定分区中的副本数量 默认一个

- --topic 指定主题名称

kafka-topics.sh --bootstrap-server node1:9092 --create --partitions 3 --replication-factor 3 --topic test1

二、查看主题

- --kafka-topics.sh

- --bootstrap-server 指定连接的kafka服务

- --list 查看所有主题

- --describe 查看详情信息

- --describe --topic itcast 查看某个主题详情信息

# 查看有哪些主题

kafka-topics.sh --bootstrap-server node1:9092 --list

# 查看所有主题详情信息

kafka-topics.sh --bootstrap-server node1:9092 --describe

# 查看某个具体主题详请

kafka-topics.sh --bootstrap-server node1:9092 --describe --topic test1

三、修改分区数

-- - kafka-topics.sh

- --bootstrap-server 指定连接的kafka服务

- --alter 修改主题

kafka-topics.sh --bootstrap-server node1:9092 --alter --partitions 3 --topic test01

四、删除主题

- --kafka-topics.sh

- --bootstrap-server 指定连接的kafka服务

- --delete 删除主题

kafka-topics.sh --bootstrap-server node1:9092 --delete --topic test01

五、生产数据

--kafka-console-producer.sh --brooker-list node1 --topic test

六、创建消费组

数据源,创建消费者组消费指定topic，并从指定 offset 开始消费数据