频道栏目
首页 > 网络 > 云计算 > 正文

Kafka操作命令罗列及分享

2018-08-04 11:30:17           
收藏   我要投稿

启动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

相关TAG标签 Kafka 操作 命令
上一篇:HDFS的shell常用操作指令
下一篇:Scrapy在windows下的安装流程实例
相关文章
图文推荐

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站