当前位置: 首页 > 知识库问答 >
问题:

无法在Windows中启动Kafka Zookeeper

鲁钱明
2023-03-14

我不明白我做错了什么。有人能帮忙吗。我成功地能够在Linux“bin/zookeeper-server-start.sh config/zookeeper.properties”中启动zookeeper和kafka服务器

共有1个答案

孙成化
2023-03-14

首先,不要忘记您使用的是windows操作系统,所以不要忘记路径.\bin\...之前的点号.

Zookeeper安装找到您的Zookeeper配置目录。例如C:\zookeeper-3.4.7\conf

找到.cfg文件,将zoo_sample.cfg复制并重命名为c:\tools\zookeeper-3.4.9\conf中的zoo_sample.cfg

查找并编辑datadir=/tmp/zookeeper:\zookeeper-3.4.7\data

此外,在系统环境变量中添加一个条目,就像您为Java所做的那样。意思是这样的

Add ZOOKEEPER_HOME = C:\zookeeper-3.4.7 to the System Variables.

添加;%zookeeper_home%\bin;

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

为了现在创建主题,您应该这样做:

>

  • 现在创建一个名称为“test”、复制因子为1的主题,因为我们只有一个Kafka服务器在运行。如果有一个集群运行多个Kafka服务器,则可以相应地增加复制因子,这将提高数据可用性,并像容错系统一样发挥作用。

    在位置C:\kafka2.12-2.1.0\bin\windows中打开一个新的命令提示符。

    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    

    创建一个简单的生产者和消费者进行测试

    在位置C:\kafka2.12-2.1.0\bin\windows中打开一个新的命令提示符,并为生产者键入以下内容:

    kafka-console-producer.bat --broker-list localhost:9092 --topic test
    

    再次在相同的位置打开一个新的命令提示符,并键入:

    kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
    

  •  类似资料:
    • 在 Windows 上执行命令将返回以下结果: 运行诊断程序会产生以下结果:

    • 在 cmd 中运行 elasticsearch.bat :

    • java 15.0.2 2021-01-19 java(TM)SE运行时环境(构建15.0.2 7-27)java热点(TM)64位服务器虚拟机(构建15.0.2 7-27,混合模式,共享)sonarqube-8.7.0.41497

    • 我已经在Windows Server 2019上安装了Minikube与Docker一起使用。但是,当我尝试从开始时,它显示以下错误: 启动超虚拟机失败。运行“minikube delete”可能会修复它:加载现有主机时出错。 Hyper-V\Start-VM minikube 无法修复此问题。 当我以

    • 我使用的是XAMPP,我可以启动Apache,但是MySQL(phpMyAdmin)可以启动! 当我开始时,我得到这个错误; 我在上面搜索,然后在配置中更改Apache的端口- 我也卸载Skype(Windows 8/10/Metro版本)。没有工作。在我httpd.conf文件中; 我通过apache\u start启动它。bat和get; 请注意,所有日志文件都不存在!Skype已卸载。

    • 问题内容: 我正在使用XAMPP,并且可以启动Apache,但是,MySQL(phpMyAdmin)已启动! 当我开始时,出现此错误; 我对其进行搜索,然后在Config-> Service and Port setting中更改Apache的端口。我有; 我还卸载了Skype(Windows 8/10 / Metro版本)。什么都没用。在httpd.conf中,我有; 我通过启动并获得; 请注意