Windows安装k1afka并测试通过

 时间:2024-10-13 19:21:35

1、下载地址选择二进制的推荐版本

Windows安装k1afka并测试通过
Windows安装k1afka并测试通过

2、选择推荐的镜像下载地址,点击后直接下载,现在完成后解压文件,并进入\bin\windows目录下。

Windows安装k1afka并测试通过
Windows安装k1afka并测试通过

3、启动zookeeper服务器:请查看Windows安装z1ookeeper

Windows安装k1afka并测试通过

4、按住shift+右键→在此处打开命令窗口,输入此命令:kafka-server-start.bat ..\..\config\server.properties,发现会报错 “找不到或无法加载主类 Files\Java\jdk\dt.jar;C:\Program Kafka”

Windows安装k1afka并测试通过

5、解决办法是找到windows下的:(1)氯短赤亻kafka-server-start.bat文件,编辑。 给 %CLASSPATH% 加上双引号 "%CLASSPATH%",如下图修改后下该地方:set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp %CLASSPATH% %KAFKA_OPTS% %*(2)再次运行4中的命令,发现可以了。(3)不过此时还抛出了一个异常说是某个文件中发现了某个异常的冒号”:“,没找解决方法,因为程序可以正常运行。 javax.management.MalformedObjectNameException: Invalid character ':' in value part of propert(4)注意此时不要关闭此窗口,因为下面创建topic等要开着这个窗口。如果关闭了此窗口,重新启动,会发现抛出大量的错误,说日志文件已经被其他进程占用(不知道为什么),解决方法是把D:\tmp\kafka-logs(默认)目录下的文件全部删除,不知道有没有好的解决方法?

Windows安装k1afka并测试通过
Windows安装k1afka并测试通过

6、创建主题:mytopics。按照5中的方式,打开命令窗口,输入:kafka-topics.bat --create --zookeeper localhost:2181 --replicat足毂忍珩ion-factor 1 --partitions 1 --topic mytopicsTest创建主题成功。查看主题命令:kafka-topics.bat --list --zookeeper localhost:2181

Windows安装k1afka并测试通过

7、打开生产者,发送数据给主题。按照5,输入:kafka-console-producer.bat --broker-list localhost:9092 --topic mytopicsTest输入:my name is xyx 回车确认。

Windows安装k1afka并测试通过

8、打开消费者,接收消息。按照5,输入:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mytopicsTest --from-beginning 发现消费者接收到了消息:my name is xyx。

Windows安装k1afka并测试通过

9、继续在生产者输入各种字符,发现消费者依次会显示出来。 至此就安装好了kafka,并测试通过。

Windows安装k1afka并测试通过
Windows安装k1afka并测试通过
  • 做完美知性美女 揭晓美臀小秘密
  • 怎么找到word的接受
  • 教学管理系统是如何构成的?
  • 薪酬管理的四大有效作用
  • 网店运营分析工具的使用
  • 热门搜索
    防震减灾手抄报资料 端午节手抄报怎么画 庆祝国庆节手抄报 缅怀先烈的手抄报内容 诚信手抄报内容 地理手抄报内容 我是小学生手抄报 儒家文化手抄报 心理健康手抄报资料 手抄报装饰小图案