深入kafka（二）.单机与伪分布式配置实战
1.下载安装
到https://www.apache.org上下载 wget http://apache.fayea.com/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz
安装： 拷贝到用户目录 cp kafka2.11-0.10.0.0.tgz /usr/local 解压：tar -zxvf kafka2.11-0.10.0.0.tgz 重命名： mv kafka_2.11-0.10.0.0 kafka
2.单机版配置
使用kafka自带的zookeeper：默认config中配置的zookeeper地址为zookeeper.connect=localhost:2181 bin/zookeeper-server-start.sh config/zookeeper.properties & bin/kafka-server-start.sh config/server.properties &
不适用自带的zookeeper，则需要修改config.properties中的zookeeper.connect为zookeeper地址 bin/kafka-server-start.sh config/server.properties &
&表示后台启动进程
停止kafka集群：bin/kafka-server-stop.sh
3.命令行测试：
3.1创建topic
3.2列出所有topic
3.3启动生产者
输入一些信息，比如hello，并且Ctrl+z退出shell
3.4启动消费者comsumer
稍等片刻就能看到你生产的消息 hello
4.伪分布式搭建：
4.1配置
每个broker代表一个kafka server端，每个broker对应一个server.properties的配置文件,我们搭建运行3个broker的伪分布式环境。配置文件分别为config/server.properties、config/server1.properties、config/server2.properties。
config/server.properties:
config/server-1.properties:
config/server-2.properties:
### 4.2启动kafka集群：
lsof -i tcp:9092 lsof -i tcp:9093 lsof -i tcp:9094分别观察端口情况
4.3 测试集群
创建一个拥有3个副本的集群
查看每个节点信息
生产信息：
消费消息：
停止kafka集群：bin/kafka-server-stop.sh
欢迎关注我的公众号，获取更多文章，并与我交流沟通。
- 发表于:
- 原文链接：http://kuaibao.qq.com/s/20180415G08E3G00?refer=cp_1026
- 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号（企鹅号）传播渠道之一，根据《腾讯内容开放平台服务协议》转载发布内容。
- 如有侵权，请联系 cloudcommunity@tencent.com 删除。
相关快讯
扫码
添加站长 进交流群
领取专属 10元无门槛券
私享最新 技术干货
腾讯云开发者
