kafka3.0常用命令


1、进入kafka的bin目录:先启动内置zookeeper

    执行命令:zookeeper-server-start.sh ../config/zookeeper.properties

    后台运行命令:zookeeper-server-start.sh -daemon ../config/zookeeper.properties

2、启动kafka

    执行命令:./kafka-server-start.sh ../config/server.properties,主义前面 ./ ,不然启动不了。

    后台启动命令:./kafka-server-start.sh -daemon ../config/server.properties

 

生产命令:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic frist0401

消费命令:
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic frist0401

 

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

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

创建topic

bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --partitions 1 --replication-factor 1 --topic first0406

 

3、查看 first 主题的详情

bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic first0406

  4、修改分区数(注意:分区数只能增加,不能减少)

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

  5、再次查看 first 主题的详情

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

  6、删除 topic

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

https://www.cnblogs.com/liyuanhong/p/12345751.html

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM