赞
踩
解压kafka,进入主目录。
mkdir logs
vi config/server.properties
需要更改几处地方
第一处:broker.id
每个kafka集群节点处的此值都必须不同,而且必须为整数,建议从1开始,设置为与zookeeper中的myid相同。
第二处:日志目录
更改为新建的日志文件夹:
第三处:指定ZK服务器
更改为所有节点对应的ip地址(名字):2181,如下所示:
最后把该目录分发到其余slave节点,同时更改每个slave节点对应的broke id。
启动kafka之前,需要安装部署好zookeeper环境,启动kafka的命令如下(前台启动方式)
bin/kafka-server-start.sh config/server.properties
成功启动后另起一个窗口,输入jps查看当前java进程,会显示kafka。成功启动后的截图如图所示:
关闭kafka的命令为:
bin/kafka-server-stop.sh
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。