本文主要向大家介绍了【云计算】Kafka常用操作指令，通过具体的内容向大家展现，希望对大家学习云计算有所帮助。

启动Kafka：

/export/servers/zookeeper/bin/zkServer.sh start

nohup /export/servers/kafka/bin/kafka-server-start.sh /export/servers/kafka/config/server.properties &

查看当前服务器中的所有topic

bin/kafka-topics.sh –list –zookeeper hadoop05:2181

创建topic

bin/kafka-topics.sh –create –zookeeper hadoop05:2181 –replication-factor 1 –partitions 1 –topic test

删除topic

bin/kafka-topics.sh –delete –zookeeper hadoop05:2181 –topic test

需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。

通过shell命令发送消息

bin/kafka-console-producer.sh –broker-list hadoop05:9092 –topic test1

通过shell消费消息

bin/kafka-console-consumer.sh –zookeeper hadoop05:2181 –from-beginning –topic gamelogs

查看消费位置

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker –zookeeper hadoop05:2181 –group testGroup

查看某个Topic的详情

bin/kafka-topics.sh –topic test –describe –zookeeper hadoop05:2181

对分区数进行修改

bin/kafka-topics.sh –zookeeper hadoop05 –alter –partitions 15 –topic utopic

本文由职坐标整理并发布，希望对同学们有所帮助。了解更多详情请关注职坐标大数据云计算大数据安全频道！