《kafka常用命令行》由会员分享，可在线阅读，更多相关《kafka常用命令行（3页珍藏版）》请在金锄头文库上搜索。
1、0.查看有哪些主题：Bash shell纯文本查看复制代码?1./kafka-topics.sh -list -zookeeper 192.168.0.201:121811.查看topic的详细信息Bash shell纯文本查看复制代码?1./kafka-topics.sh -zookeeper 127.0.0.1:2181 -describe -topic testKJ12、为topic增加副本Bash shell纯文本查看复制代码?1./kafka-reassign-partitions.sh -zookeeper 127.0.0.1:2181 -reassignment-json-fil
2、e json/partitions-to-move.json -execute3、创建topicBash shell纯文本查看复制代码?1./kafka-topics.sh -create -zookeeper localhost:2181 -replication-factor 1 -partitions 1 -topic testKJ14、为topic增加partitionBash shell纯文本查看复制代码?1./bin/kafka-topics.sh zookeeper 127.0.0.1:2181 alter partitions 20 topic testKJ15、kafka生产
3、者客户端命令Bash shell纯文本查看复制代码?1./kafka-console-producer.sh -broker-list localhost:9092 -topic testKJ16、kafka消费者客户端命令Bash shell纯文本查看复制代码?1./kafka-console-consumer.sh -zookeeper localhost:2181 -from-beginning -topic testKJ17、kafka服务启动Bash shell纯文本查看复制代码?1./kafka-server-start.sh -daemon ./config/server.pro
4、perties 8、下线brokerBash shell纯文本查看复制代码?12./kafka-run-class.sh kafka.admin.ShutdownBroker -zookeeper 127.0.0.1:2181 -broker #brokerId# -num.retries 3 -retry.interval.ms 60shutdown broker9、删除topicBash shell纯文本查看复制代码?12./kafka-run-class.sh kafka.admin.DeleteTopicCommand -topic testKJ1 -zookeeper 127.0.0
5、.1:2181./kafka-topics.sh -zookeeper localhost:2181 -delete -topic testKJ110、查看consumer组内消费的offsetBash shell纯文本查看复制代码?12./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker -zookeeper localhost:2181 -group test -topic testKJ1./kafka-consumer-offset-checker.sh -zookeeper 192.168.0.201:12181 -group g
6、roup1 -topic group111、关闭Bash shell纯文本查看复制代码?1/usr/local/kafka/bin/kafka-server-stop.shkafka-server-stop.sh后面需要配置文件如下面bin/kafka-server-stop.sh config/server.properties，有时候不能停止，可以使用暴力了。12、添加开机启动Bash shell纯文本查看复制代码?1234echo # start kafka/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafk
7、a/config/server.properties /etc/rc.local13.把文件数据导入kafkacat collection_data_20170923_00.txt | kafka-console-producer -broker-list 192.168.1.135:9092,192.168.1.137:9092,192.168.1.138:9092 -topic devicetest1查看导入的结果：kafka-console-consumer -zookeeper 192.168.1.135:2181,192.168.1.137:2181,192.168.1.138:2181 -topic devicetest1 -from-beginning
