win系统下的Kafka操作

修改kafka\bin\windows\kafka-run-class.bat文件。具体修改内容是：

set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp %CLASSPATH% %KAFKA_OPTS% %
改为：
set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp "%CLASSPATH%" %KAFKA_OPTS% %

%CLASSPATH% 要用双引号。

进入kafka目录下,新建文件夹my-kafka-logs与文件夹my-zk-dir，进入config目录下，打开server.properties

broker.id=1
log.dirs=C:\\kafka\\my-kafka-logs

打开zookeeper.properties

dataDir=C:\\kafka\\my-zk-dir

启动zookeeper, 打开cmd，cd到kafka\bin\windows目录下，执行命令

zookeeper-server-start.bat ..\..\config\zookeeper.properties

启动kafka，另外再开一个cmd, cd到kafka目录下，执行命令

.\bin\windows\kafka-server-start.bat    .\config\server.properties

启动完成。