kafka常用命令行.doc

0.查看有哪些主题：Bash shell纯文本查看复制代码?1./kafka-topics.sh -list -zookeeper 01:121811.查看topic的详细信息Bash shell纯文本查看复制代码?1./kafka-topics.sh -zookeeper :2181 -describe -topic testKJ12、为topic增加副本Bash shell纯文本查看复制代码?1./kafka-reassign-partitions.sh -zookeeper :2181 -reassignment-json-file 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 :2181 alter partitions 20 topic testKJ15、kafka生产者客户端命令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/perties 8、下线brokerBash shell纯文本查看复制代码?12./kafka-run-class.sh kafka.admin.ShutdownBroker -zookeeper :2181 -broker #brokerId# -num.retries 3 -erval.ms 60shutdown broker9、删除topicBash shell纯文本查看复制代码?12./kafka-run-class.sh kafka.admin.DeleteTopicCommand -topic testKJ1 -zookeeper :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 01:12181 -group group1 -topic group111、关闭Bash shell纯文本查看复制代码?1/usr/local/kafka/bin/kafka-server-stop.shkafka-server-stop.sh后面需要配置文件如下面bin/kafka-server-stop.sh config/perties，有时候不能停止，可以使用暴力了。12、添加开机启动Bash shell纯文本查看复制代码?1234echo # start kafka/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/perties /etc/rc.local13.把文件数据导入kafkacat collection_data_20170923_00.txt | kafka-console-producer -broker-list 35:9092,37:9092,38:9092 -topic devicetest1查看导入的结果：kafka-console-consu