标签:
最近做一个项目的POC测试,打通了DB2->OGG->KAFKA->SPARK STREAMING->SEQUOIADB整套流程, 完成数据的实时更新,下面讲下kafka的安装
kafka的安装需要zookeeper,kafka自己带了zookeeper组件,只要自己配置下config/zoookeeper.properties 文件,然后启动就可以了,该文件的配置和zookeeper自带的配置文件一样的。
dataDir=/tmp/zookeeper # the port at which the clients will connect clientPort=2181 # disable the per-ip limit on the number of connections since this is a non-production config maxClientCnxns=0 server.1
配置dataDir, 然后在该目录下生成一个myid文件,填入zookeeper的id
添加server进行 例如:server.1:2888:3888
然后启动zookeeper:
./bin/zookeeper-server-start.sh config/zookeeper.properties &
看启动成功没,多个zookeeper就在多天机器上执行该命令
下面配置kafka的配置文件,
zookeeper.connect=localhost:2181 #host.name=localhost broker.id=0
broker.id和zookeeper的myid有点像
启动kafka
./bin/kafka-server-start config/server.properties &
OK,有啥不懂的留言。
标签:
原文地址:http://www.cnblogs.com/gaoxing/p/4522034.html