深入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
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。

扫码关注云+社区

领取腾讯云代金券