kafka shell操作

操作"/>

kafka shell操作

目录

• • 查看当前服务器中的所有topic
  • 创建topic
  • 查看某个Topic的详情
  • 修改分区数（注意：分区数只能增加，不能减少）
  • 删除topic
  • 生产数据
  • 消费数据

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

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

没有主题时，什么也不会输出

创建topic

创建一个topic，有1个分区3个副本

选项说明：

–topic 定义topic名
–replication-factor 定义副本数
–partitions 定义分区数

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

查看某个Topic的详情

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

修改分区数（注意：分区数只能增加，不能减少）

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

删除topic

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

注意：需要彻底删除topic，须在server.properties中设置delete.topic.enable=true，否则只是标记删除

生产数据

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

消费数据

#把主题中所有的数据都读取出来（包括历史数据）
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first --from-beginning #从上一次的最大的偏移量处进行消费
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first