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

启动完成。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 大致可以通过上述情况进行排除 1.kafka服务器问题 查看日志是否有报错,网络访问问题等。 2. kafka p...
    生活的探路者阅读 7,668评论 0 10
  • 一、入门1、简介Kafka is a distributed,partitioned,replicated com...
    HxLiang阅读 3,465评论 0 9
  • 一、基本概念 介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独...
    ITsupuerlady阅读 1,667评论 0 9
  • 2017,有效沟通,阳光森林空中课堂,今晚课程20:30开始、今晚课程非常重要。 关于信任,今天我们换一个角度谈这...
    建设现代生活阅读 538评论 0 0
  • 坚持分享第298天 2018.7.3 最近几天,由于身体原因,脾气不太好,正因为如此,更能体验到家庭的...
    潼妈_tong阅读 590评论 0 0