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
因篇幅问题不能全部显示,请点此查看更多更全内容
怀疑对方AI换脸可以让对方摁鼻子 真人摁下去鼻子会变形
女子野生动物园下车狼悄悄靠近 后车司机按喇叭提醒
睡前玩8分钟手机身体兴奋1小时 还可能让你“变丑”
惊蛰为啥吃梨?倒春寒来不来就看惊蛰
男子高速犯困开智能驾驶出事故 60万刚买的奔驰严重损毁