A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

本帖最后由 梦缠绕的时候 于 2019-1-10 11:06 编辑

1.下载地址
http://mirrors.tuna.tsinghua.edafka_2.12-2.1.0.tgz

2.启动zookeeper服务器
2.1修改zookeeper的配置文件信息
zookeeper版本为3.4.13
找到zookeeper的配置文件(将config文件夹下的zoo_sample.cfg文件重命名为zoo.cfg)
在配置文件中添加以下2行内容,配置zookeeper的data和logs存放目录,clientPort默认为2181,为zookeeper程序启动后的占用端口

dataDir=E:/zookeeper-3.4.13/data   
dataLogDir=E:/zookeeper-3.4.13/logs  

2.2创建zookeeper-start.bat批处理程序
@echo off
E:(zookeeper盘符)
cd\zookeeper-3.4.13\bin(zookeeper目录)
start zkServer.cmd

3.启动kafka服务器
3.1修改kafka的配置文件
路径为安装目录下的config文件夹中的server.properties文件
如果zookeeper的端口有修改,则需要修改zookeeper.connect的对应端口
硒鼓log.dirs的路径,存储kafka日志

zookeeper.connect=localhost:2181
log.dirs=E:\\kafka_2.12-2.1.0\\kafka-logs

3.2创建kafka-start.bat批处理程序
@echo off
E:(kafka安装盘符)
cd\kafka_2.12-2.1.0\bin\windows(kafka安装目录下的windows文件夹)
start kafka-server-start.bat ../../config/server.properties(启动kafka程序)

4.确认程序启动成功
在cmd窗口中运行jps,看到以下进程表示启动成功,其中QuorumPeerMain是ZooKeeper守护进程,另一个是Kafka守护进程。


5.注意:
kafka报以下错误时,需要jvm环境为64位jdk
java.io.IOException: Map failed
Caused by: java.lang.OutOfMemoryError: Map failed

1 个回复

倒序浏览
奈斯
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马