我已经下载了Kafka2.12-2.1.0并将其放在文件夹路径“c:\Kafka2.12-2.1.0”中。为了启动kafka zookeeper,我在命令提示符下执行了下面的命令,
c:\kafka\u 2.12-2.1.0>bin\windows\zookeeper-server-start.bat config\zookeeper.properties
我收到如下错误消息,
命令语法不正确。文件名、目录名或卷标语法不正确。
我不明白我做错了什么。有人能帮忙吗。我能够在linux“bin/zookeeper-server-start.sh config/zookeeper.properties”中成功地启动zookeeper和kafka服务器
1条答案
按热度按时间kokeuurv1#
首先,别忘了你在windows操作系统中,所以别忘了点
.
在小路前面.\bin\...
zookeeper安装找到zookeeper配置目录。例如C:\zookeeper-3.4.7\conf
.定位
.cfg
文件、复制和重命名zoo_sample.cfg
至zoo.cfg
在C:\Tools\zookeeper-3.4.9\conf
用任何文本编辑器打开它,比如记事本++查找和编辑
dataDir=/tmp/zookeeper to :\zookeeper-3.4.7\data
另外,在系统环境变量中添加一个条目,就像对java所做的那样。意思是这样的添加
;%ZOOKEEPER_HOME%\bin;
打开一个新命令并键入以下内容,运行zookeeper:zkserver
.Kafka服务器
运行kafka服务器类型
创建主题
要立即创建主题,您应该执行以下操作:
现在创建一个名为“test”且复制因子为1的主题,因为我们只有一个kafka服务器在运行。如果您有一个运行多个kafka服务器的集群,则可以相应地增加复制因子,这将提高数据可用性,并起到容错系统的作用。
在位置c:\kafka\u 2.12-2.1.0\bin\windows中打开一个新的命令提示符。
键入以下命令并按enter键:
创建一个简单的生产者和消费者来测试
在位置c:\kafka\u 2.12-2.1.0\bin\windows中打开一个新的命令提示符,并为生产者键入以下命令:
再次在相同的位置和类型中打开新的命令提示符:
看看这篇文章你会发现它很有用