搜索
您的当前位置:首页正文

Kafka命令使用

来源:意榕旅游网

kafka启动命令:kafka-server-start.sh -daemon  (后台运行)

kafka关闭命令:kafka-server-stop.sh

创建topic命令:

kafka-topics.sh --create --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1 --partitions 3 --replication-factor 3

修改topic命令:

kafka-topics.sh --alter --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1 --partitions 4  (修改分区数,只能增加,不能减少)

查看所有的topic命令:

kafka-topics.sh --list --bootstrap-server master:2181,slave1:2181,slave2:2181

查看某个topic的详细信息命令:

kafka-topics.sh --describe --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1

删除topic命令:

kafka-topics.sh --delete --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1

生产数据命令:(用于测试)

kafka-console-producer.sh --bootstrap-server master:9092,slave1:9092,slave2:9092 --topic test1

消费数据命令:(用于测试)

kafka-console-consumer.sh --topic test1 --bootstrap-server master:9092,slave1:9092,slave2:9092

可消费到历史数据

kafka-console-consumer.sh --topic test1 --bootstrap-server master:9092,slave1:9092,slave2:9092

--from-beginning

因篇幅问题不能全部显示,请点此查看更多更全内容

热门图文

Top