kafka常用命令行

《kafka常用命令行》由会员上传分享，免费在线阅读，更多相关内容在应用文档-天天文库。

1、0.查看有哪些主题： [Bashshell] 纯文本查看 复制代码?1./kafka-topics.sh--list--zookeeper192.168.0.201:121811.查看topic的详细信息[Bashshell] 纯文本查看 复制代码?1./kafka-topics.sh-zookeeper127.0.0.1:2181-describe-topictestKJ12、为topic增加副本[Bashshell] 纯文本查看 复制代码?1./kafka-reassign-partitions.sh-zookeeper

2、127.0.0.1:2181-reassignment-json-filejson/partitions-to-move.json-execute3、创建topic[Bashshell] 纯文本查看 复制代码?1./kafka-topics.sh--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topictestKJ14、为topic增加partition[Bashshell] 纯文本查看 复制代码?1./bin/kafka-topics

3、.sh–zookeeper127.0.0.1:2181–alter–partitions20–topictestKJ15、kafka生产者客户端命令[Bashshell] 纯文本查看 复制代码?1./kafka-console-producer.sh--broker-listlocalhost:9092--topictestKJ16、kafka消费者客户端命令[Bashshell] 纯文本查看 复制代码?1./kafka-console-consumer.sh-zookeeperlocalhost:2181--from-be

4、ginning--topictestKJ17、kafka服务启动[Bashshell] 纯文本查看 复制代码?1./kafka-server-start.sh-daemon../config/server.properties8、下线broker[Bashshell] 纯文本查看 复制代码?12./kafka-run-class.shkafka.admin.ShutdownBroker--zookeeper127.0.0.1:2181--broker#brokerId#--num.retries3--retry.interv

5、al.ms60shutdownbroker9、删除topic[Bashshell] 纯文本查看 复制代码?12./kafka-run-class.shkafka.admin.DeleteTopicCommand--topictestKJ1--zookeeper127.0.0.1:2181./kafka-topics.sh--zookeeperlocalhost:2181--delete--topictestKJ110、查看consumer组内消费的offset[Bashshell] 纯文本查看 复制代码?12./kafka-

6、run-class.shkafka.tools.ConsumerOffsetChecker--zookeeperlocalhost:2181--grouptest--topictestKJ1./kafka-consumer-offset-checker.sh--zookeeper192.168.0.201:12181--groupgroup1--topicgroup111、关闭[Bashshell] 纯文本查看 复制代码?1/usr/local/kafka/bin/kafka-server-stop.shkafka-serv

7、er-stop.sh后面需要配置文件如下面bin/kafka-server-stop.shconfig/server.properties，有时候不能停止，可以使用暴力了。 12、添加开机启动[Bashshell] 纯文本查看 复制代码?1234echo‘#startkafka/usr/local/kafka/bin/kafka-server-start.sh-daemon/usr/local/kafka/config/server.properties‘>>/etc/rc.local13.把文件数据导入kafkacatco

8、llection_data_20170923_00.txt

9、kafka-console-producer--broker-list192.168.1.135:9092,192.168.1.137:9092,192.168.1.138:9092--topicdevicetest1查看导入的结