查看: 236|回复: 5

Kafka常用命令使用说明

[复制链接]
论坛徽章:
1
spark徽章
日期:2019-08-01 16:31:52
发表于 2019-6-12 10:54 | 显示全部楼层 |阅读模式

Kafka

https://blog.csdn.net/lkforce/article/details/77776684
回复

使用道具 举报

新浪微博达人勋 xenron  实名认证
论坛徽章:
251
股票徽章
日期:2019-09-12 14:42:59spark徽章
日期:2019-09-19 15:44:06人工智能徽章
日期:2019-09-19 15:47:00区块链徽章
日期:2019-09-19 15:47:29python徽章
日期:2019-09-19 15:47:56
发表于 2019-6-14 22:55 | 显示全部楼层
kafka-topics.sh --list --zookeeper127.0.0.1:2181

列出该zookeeper中记录在案的topic列表,只有名字
回复 支持 反对

使用道具 举报

新浪微博达人勋 xenron  实名认证
论坛徽章:
251
股票徽章
日期:2019-09-12 14:42:59spark徽章
日期:2019-09-19 15:44:06人工智能徽章
日期:2019-09-19 15:47:00区块链徽章
日期:2019-09-19 15:47:29python徽章
日期:2019-09-19 15:47:56
发表于 2019-6-14 22:56 | 显示全部楼层
kafka-topics.sh --create --topic test0--zookeeper 127.0.0.1:2181 --config max.message.bytes=12800000 --config flush.messages=1 --partitions 5 --replication-factor 1

说明:

--topic后面的test0是topic的名称

--zookeeper应该和server.properties文件中的zookeeper.connect一样

--config指定当前topic上有效的参数值

--partitions指定topic的partition数量,如果不指定该数量,默认是server.properties文件中的num.partitions配置值

--replication-factor指定每个partition的副本个数,默认1个
回复 支持 反对

使用道具 举报

新浪微博达人勋 xenron  实名认证
论坛徽章:
251
股票徽章
日期:2019-09-12 14:42:59spark徽章
日期:2019-09-19 15:44:06人工智能徽章
日期:2019-09-19 15:47:00区块链徽章
日期:2019-09-19 15:47:29python徽章
日期:2019-09-19 15:47:56
发表于 2019-6-14 22:56 | 显示全部楼层
删除kafka的topic

命令:

bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic test0

如果server.properties中没有把delete.topic.enable设为true,那么此时的删除并不是真正的删除,而是把topic标记为:marked for deletion
回复 支持 反对

使用道具 举报

新浪微博达人勋 xenron  实名认证
论坛徽章:
251
股票徽章
日期:2019-09-12 14:42:59spark徽章
日期:2019-09-19 15:44:06人工智能徽章
日期:2019-09-19 15:47:00区块链徽章
日期:2019-09-19 15:47:29python徽章
日期:2019-09-19 15:47:56
发表于 2019-6-14 22:56 | 显示全部楼层
删除kafka中该topic相关的目录。

在server.properties中找到配置log.dirs,把该目录下test0相关的目录删掉
回复 支持 反对

使用道具 举报

新浪微博达人勋 xenron  实名认证
论坛徽章:
251
股票徽章
日期:2019-09-12 14:42:59spark徽章
日期:2019-09-19 15:44:06人工智能徽章
日期:2019-09-19 15:47:00区块链徽章
日期:2019-09-19 15:47:29python徽章
日期:2019-09-19 15:47:56
发表于 2019-6-14 22:56 | 显示全部楼层
登录zookeeper client。

命令:

/home/ZooKeeper/bin/zkCli.sh
回复 支持 反对

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册 新浪微博登陆

本版积分规则

 

GMT+8, 2019-9-20 15:22 , Processed in 0.132298 second(s), 39 queries .

关闭

扫一扫加入
本版微信群