kafka basic commands
2015-07-05 10:28
246 查看
kafka-server-start.sh config/server.properties &
kafka-server-stop.sh
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafkatopic
kafka-topics.sh --list --zookeeper localhost:2181
kafka-console-producer.sh --broker-list namenode:9092 --topic kafkatopic
kafka-console-consumer.sh --zookeeper namenode:2181 --topic kafkatopic --from-beginning
1.how to delete topic
删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录
删除zookeeper "/brokers/topics/"目录下相关topic节点
sample code:
ls /brokers/topics/
rmr /brokers/topics/kafkaToptic
让一个人迅速成长的最简单、最直接也是最有效的办法就是:迅速地让他看到自己的不足
当你有不可思议的目标时,你的人生就必定会有不可思议的改变
2.查看kafka 在zookeeper上面结点的情况
zkCli.sh
ls /
ls /dir/dir/dir/dir/dir
kafka-server-stop.sh
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafkatopic
kafka-topics.sh --list --zookeeper localhost:2181
kafka-console-producer.sh --broker-list namenode:9092 --topic kafkatopic
kafka-console-consumer.sh --zookeeper namenode:2181 --topic kafkatopic --from-beginning
1.how to delete topic
删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录
删除zookeeper "/brokers/topics/"目录下相关topic节点
sample code:
ls /brokers/topics/
rmr /brokers/topics/kafkaToptic
让一个人迅速成长的最简单、最直接也是最有效的办法就是:迅速地让他看到自己的不足
当你有不可思议的目标时,你的人生就必定会有不可思议的改变
2.查看kafka 在zookeeper上面结点的情况
zkCli.sh
ls /
ls /dir/dir/dir/dir/dir
相关文章推荐
- gruntjs教程实例(cssmin)
- 51nod 1352:集合计数
- C++ Primer学习笔记(10)——如何读写文件
- 《C语言及程序设计》实践参考——链表的合并
- vsftp软链接ln遇到550错误
- 数据结构基础温故-3.队列
- 接口回调Callback
- HDU 1829 A Bug's Life(种类并查集)
- 工作中经常打交道的Java代码の容器(一)
- 调试程序时,为什么内存代码段填充{烫烫烫烫烫烫烫烫烫烫}
- javascript作用域总结
- JAVA23种设计模式
- 终端,虚拟终端和伪终端
- 《C语言及程序设计》实践项目——链表初步
- 提高团队代码质量
- C# String与StringBuilder
- Windows批处理:自动检查服务器连通性
- CALayer(二)创建新图层
- visual C++ 2003
- CONST的用法小结: