当前位置: > CentOS教程 > 软件安装教程 >

CentOS 6.7安装Kafka 0.10.1

时间:2016-12-04 02:06来源:blog.csdn.net 作者:Noob_f 举报 点击:

master

[root@master ~]# wget http://apache.fayea.com/kafka/0.10.1.0/kafka_2.10-0.10.1.0.tgz
[root@master ~]# tar -zxvf kafka_2.10-0.10.1.0.tgz
[root@master ~]# mv kafka_2.10-0.10.1.0 /usr/local/

[root@master ~]# vi /usr/local/kafka_2.10-0.10.1.0/config/server.properties
  1. 修改

    zookeeper.connect=localhost:2181

    zookeeper.connect=master:2181,slave:2181
  2. 添加

    host.name=master

保存退出


[root@master ~]# rsync -av /usr/local/kafka_2.10-0.10.1.0 slave:/usr/local/

slave

[root@slave ~]# vi /usr/local/kafka_2.10-0.10.1.0/config/server.properties

修改

broker.id=0
host.name=master

broker.id=1
host.name=slave

保存退出

启动Kafka

master

[root@master ~]# cd /usr/local/kafka_2.10-0.10.1.0/
[root@master kafka_2.10-0.10.1.0]# bin/kafka-server-start.sh -daemon config/server.properties

slave

[root@slave ~]# cd /usr/local/kafka_2.10-0.10.1.0/
[root@slave kafka_2.10-0.10.1.0]# bin/kafka-server-start.sh -daemon config/server.properties

  • 最后,检验是否安装成功。使用 Kafka 自带的客户端检测。进入 Kafka 安装主目录,先启动生产者进入交互客户端模式

master

创建一个名为 test 的主题

[root@master kafka_2.10-0.10.1.0]# bin/kafka-topics.sh --create --zookeeper master:2181 --replication-factor 1 --partitions 1 --topic test

在一个终端上启动一个生产者

[root@master kafka_2.10-0.10.1.0]# bin/kafka-console-producer.sh --broker-list master:9092 --topic test

slave

在另一个终端中启动消费者,进入交互客户端

[root@slave kafka_2.10-0.10.1.0]# bin/kafka-console-consumer.sh --zookeeper master:2181 --topic test --from-beginning

在master(生产者)上,键盘输入Hello World!;之后在slave(消费者)上,屏幕有同样的信息输出。证明 Kafka 集群已经搭建成功。

------分隔线----------------------------
发表评论
为了和诣的生活,我关闭了评论页面,请大家到QQ群里交流吧:348944156,也欢迎关注本站微信公众号:centoscn