kafka命令行脚本使用
2018-01-14 17:36
246 查看
zookeeper集群部署:http://www.cnblogs.com/ding2016/p/8280696.html
kafka集群部署:http://www.cnblogs.com/ding2016/p/8282907.html
测试环境:
测试流程:①主线:创建topoic,生产消息,消费消息;
②流程命令会连接不同的节点,可以顺带检测集群消息同步情况;
测试步骤:
1. 先创建一个Topic
[root@server-1 bin]# ./kafka-topics.sh --create --zookeeper 192.168.1.21:2181 --replication-factor 3 --partitions 2 --topic google
2. 查看一下建好的Topic
[root@server-1 bin]# ./kafka-topics.sh --list --zookeeper 192.168.1.23:2181
3. 在建好的Topic下生产消息
[root@server-1 bin]# ./kafka-console-producer.sh --broker-list 192.168.1.21:9092 --topic google
4. 消费指定Topic下的消息
[root@server-1 bin]# ./kafka-console-consumer.sh --zookeeper 192.168.1.22:2181 --topic google --from-beginning
5. 删除指定Topic
先list一下,然后删除:
[root@server-1 bin]# ./kafka-topics.sh --delete --zookeeper 192.168.1.23:2181 --topic google
结束.
kafka集群部署:http://www.cnblogs.com/ding2016/p/8282907.html
测试环境:
测试流程:①主线:创建topoic,生产消息,消费消息;
②流程命令会连接不同的节点,可以顺带检测集群消息同步情况;
测试步骤:
1. 先创建一个Topic
[root@server-1 bin]# ./kafka-topics.sh --create --zookeeper 192.168.1.21:2181 --replication-factor 3 --partitions 2 --topic google
2. 查看一下建好的Topic
[root@server-1 bin]# ./kafka-topics.sh --list --zookeeper 192.168.1.23:2181
3. 在建好的Topic下生产消息
[root@server-1 bin]# ./kafka-console-producer.sh --broker-list 192.168.1.21:9092 --topic google
4. 消费指定Topic下的消息
[root@server-1 bin]# ./kafka-console-consumer.sh --zookeeper 192.168.1.22:2181 --topic google --from-beginning
5. 删除指定Topic
先list一下,然后删除:
[root@server-1 bin]# ./kafka-topics.sh --delete --zookeeper 192.168.1.23:2181 --topic google
结束.
相关文章推荐
- Linux下命令行压缩照片或图片的脚本 (ImageMagick使用心得,convert,import,display实例)
- 使用命令行运行JMeter脚本
- Windows 7和SUSE 11系统使用命令行导入导出mysql数据库sql脚本
- 使用getopt命令解析shell脚本的命令行选项
- 使用 Perl 脚本实现交互式命令行程序的管理与测试自动化
- 使用Windows命令行脚本,每天备份你的数据
- 使用getopt命令解析shell脚本的命令行选项
- 如何使用windows命令行(cmd)脚本远程下载文件
- Linux下命令行压缩照片或图片的脚本 (ImageMagick使用心得,convert,import,display实例)
- 使用命令行方式运行 JMeter 脚本
- Linux命令行与shell脚本(13)--在函数中使用普通变量
- 如何通过Linux命令行使用和运行PHP脚本
- 使用Django启动命令行及执行脚本的方法
- kafka命令行使用
- Linux命令行与shell脚本(15)--sed使用
- windows:icacls命令行修改文件使用默认继承的ACL及ant脚本实现
- Kafka 命令行使用高级篇
- mysql必知必会,使用命令行创建数据源,执行create.sql脚本文件,用populate.sql文件填充各个新表
- 使用命令行执行JMETER脚本
- 使用 Perl 脚本实现交互式命令行程序的管理与测试自动化