Kafka操作
目录
一、创建主题
二、查看主题
三、修改分区数
四、删除主题
五、生产数据
六、创建消费组
一、创建主题
--- 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 开始消费数据
