标签:
本文环境如下:
操作系统:CentOS 6 32位
JDK版本:1.8.0_77 32位
Kafka版本:0.9.0.1(Scala 2.11)
Kafka使用可以有多种模式,包括单节点单Broker,单节点多Broker,多节点多Broker。
这里我们简单区分一下:
单节点单Broker:在单台机子上,启动了一个Kafka实例(上一篇就是这种模式)。
单节点多Broker:在同一台机子上开启多个Kafka(类似Hadoop的伪分布式)。
多节点多Broker:在多台机子上分别开启多个Kafka。
将上一篇单节点单Broker的Kafka文件夹复制1份为Kafka2。
(1)修改第一个Kafka的server.properties中的以下内容:
broker.id=0
port=9092
host.name=master
(2)修改第二个Kafka的server.properties中的以下内容:
broker.id=1
port=9093 //端口号要与其他同主机的实例不同
host.name=master
先要确保zookeeper
已启动,然后分别在2个Kafka的目录执行
bin/kafka-server-start.sh config/server.properties&
如果无报错则说明启动成功
将第六步的Kafka文件夹复制2份到另外2台服务器上slave1和slave2,分别为Kafka3,Kafka4。
(1)修改第三个Kafka的server.properties中的以下内容:
broker.id=2
port=9092
host.name=slave1
(2)修改第四个Kafka的server.properties中的以下内容:
broker.id=3
port=9092
host.name=slave2
先要确保zookeeper
已启动,然后分别在3台主机上所有的Kafka目录执行
bin/kafka-server-start.sh config/server.properties&
如果无报错则说明启动成功
标签:
原文地址:http://blog.csdn.net/lnho2015/article/details/51353018