kafka集群安装
2016-04-22 15:39
253 查看
前期准备:zookeeper集群安装:
zookeeper集群安装点击这里
集群安装
1、解压
2、修改server.properties
broker.id=1
zookeeper.connect=hadoop-master:2181,hadoop-master:2181,hadoop-master:2181
3、将zookeeper集群启动
4、在每一台节点上启动broker
bin/kafka-server-start.sh config/server.properties
5、在kafka集群中创建一个topic
bin/kafka-topics.sh –create –zookeepeprr weekend05:2181 –replication-factor 3 –partitions 1 –topic order
6、用一个producer向某一个topic中写入消息
bin/kafka-console-producer.sh –broker-list weekend:9092 –topic order
7、用一个comsumer从某一个topic中读取信息
bin/kafka-console-consumer.sh –zookeeper weekend05:2181 –from-beginning –topic order
8、查看一个topic的分区及副本状态信息
bin/kafka-topics.sh –describe –zookeeper weekend05:2181 –topic order
zookeeper集群安装点击这里
集群安装
1、解压
2、修改server.properties
broker.id=1
zookeeper.connect=hadoop-master:2181,hadoop-master:2181,hadoop-master:2181
3、将zookeeper集群启动
4、在每一台节点上启动broker
bin/kafka-server-start.sh config/server.properties
5、在kafka集群中创建一个topic
bin/kafka-topics.sh –create –zookeepeprr weekend05:2181 –replication-factor 3 –partitions 1 –topic order
6、用一个producer向某一个topic中写入消息
bin/kafka-console-producer.sh –broker-list weekend:9092 –topic order
7、用一个comsumer从某一个topic中读取信息
bin/kafka-console-consumer.sh –zookeeper weekend05:2181 –from-beginning –topic order
8、查看一个topic的分区及副本状态信息
bin/kafka-topics.sh –describe –zookeeper weekend05:2181 –topic order
相关文章推荐
- 表达式
- 在同一个页面使用多个不同的jQuery版本,让它们并存而不冲突
- MicroERP开发技术分享:vsFlexGrid、scriptControl实现工资表自定义列与表间关系计算
- py2exe使用中遇到的几个问题
- DataTables封装的操作
- 第六届福建省大学生程序设计竞赛(FZU2212—FZU2221)
- OpenCV杂记06---形态学、膨胀和腐蚀
- gmp大数运算库 window下安装配置和使用(上)
- 基于saltstack实现的配置集中化管理
- AS5600 桂林银行桌面虚拟化里的黑科技
- MYSQL企业常用架构与调优经验分享
- centos下完全卸载mysql
- SIFT图像特征提取 python3.4 + opencv3.1.0代码
- SQL注入之我见
- 关于你没有权限在此位置中保存文件的问题解决
- 数据结构和算法分析
- MD5加密算法(salt盐加密)
- mac intellj IDE下tomcat catalina.sh error=13, Permission denied和error =1 Operation not permitted
- 初识io.js
- 各种类型转化为String