windows下部署kafka日记_20150514.pdf

windows下部署kafka 日记 一、下载 去apache的官网 （/downloads.html）下载最新的二进制版的压 缩 。目前的最新版本是kafka_2.11-.tgz。 二、解压 直接解压到D盘根目录下。 三、修改配置文件 注意版本不同，可能配置文件不同。请参照实际情况修改。 1．修改perties文件中的“kafka.logs.dir=logs ”为“kafka.logs.dir=/tmp/logs”。 2．修 改 perties 文 件 中 的 4 处 “File=logs/server.log ” 为 “File=/tmp/logs/server.log”。 3．复 制 config/perties 为 第一个节点perties，修改如下内容： broker.id=9093 port=9093 =localhost log.dirs=/tmp/kafka-logs-9093 4．复 制 config/perties 为 第一个节点perties，修改如下内容： broker.id=9094 port=9094 =localhost log.dirs=/tmp/kafka-logs-9094 四、修改启动文件 删除所有不能在windows下运行的*.sh文件。复制kafka_2.11-/bin/windows/*.bat 到kafka_2.11-/bin 目录下。 1．修改zookeeper-server-start.bat文件中的 “%~dp0../../”为 “%~dp0/../”。 2．修改kafka-server-start.bat文件中的 “%~dp0../../”为 “%~dp0/../”。 3．修改kafka-run-class.bat文件中的 “pushd %~dp0..\..”为 “pushd %~dp0”。 修改kafka-run-class.bat文件中的“%BASE_DIR%/config”为“%BASE_DIR%/../config”。 将kafka-run-class.bat文件中的如下内容： remClasspathadditionfor kafka-coredependencies for %%iin(%BASE_DIR%\core\build\dependant-libs-%SCALA_VERSION%\*.jar)do( call:concat%%i ) remClasspathadditionfor kafka-perfdependencies for %%iin(%BASE_DIR%\perf\build\dependant-libs-%SCALA_VERSION%\*.jar)do( call:concat%%i ) remClasspathadditionfor kafka-clients for %%iin(%BASE_DIR%\clients\build\libs\kafka-clients-*.jar)do( call:concat%%i ) remClasspathadditionfor kafka-examples for %%iin(%BASE_DIR%\examples\build\libs\kafka-examples-*.jar)do( call:concat%%i ) remClasspathadditionfor contrib/hadoop-consumer for %%i in (%BASE_DIR%\contrib\hadoop-consumer\build\libs\kafka-hadoop-consumer-*.jar) do( call:concat%%i ) remClasspathadditionfor contrib/hadoop-producer for %%i in (%BASE_DIR%\contrib\hadoop-producer\build\libs\kafka-hadoop-producer-*.jar) do ( call:concat%%i ) remClasspa