kafka开发环境搭建

发布于 2021-11-18 17:14:05 字数 1062 浏览 738 评论 3

@FrankHui 你好,想跟你请教个问题:kafka开发环境搭建时,在windows下运行java项目,报:Unable to connect to zookeeper server within timeout: 6000,在windows下ping liunx地址是可以ping通的。

将其打包jar,放到linux环境下,执行java -jar kafka_test.java Dclasspath=javatest/lib/,报找不到kafka.producer.ProducerConfig这个类,具体信息如图:

但是我直接在linux下执行:bin/kafka-console-producer.sh --zookeeper 172.16.0.32:2181 --topic test 是没有问题的。而且执行完bin/kafka-console-consumer.sh --zookeeper 172.16.0.32:2181 --topic test --from-beginning 是可以正常发送信息的。(已将config目录下server.properties中的hostname改为172.16.0.32)

jar中main函数对应的类源代码如:

为什么执行不成功呢?而且我有个疑问,在java代码中要读取kafka的配置文件,但是没有指定kafka配置文件的文件名和所在目录,这种情况下,它是怎样能找到正确的配置文件的?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(3

可是我不能没有你 2021-11-23 17:45:08

请问kafka是不是只能部署到Linux上,windows上可以部署吗?

 

本宫微胖 2021-11-23 08:45:24

解决方案:在java工程中,新建名为:MANIFEST.MF,打开该文件,加入一下内容:主要作用就是指定当该工程打成jar之后的运行主函数以及引入的第三方jar包。

将该java工程打成jar包时,需要注意在第三步骤时选择如图所示:

打包成功之后,将jar包上传至linux下,并在当前目录下信件lib目录,将MANIFEST.MF中引入的jar包全部copy进去。

然后就可以执行jar包了:java -jar kafka_test.jar,如图:

consumer端已成功接收到消息,如:

终于成功了,非常感谢@FrankHui ,对于我学习kafka有很大的帮助,同时期待你更多精彩详细的kafka文章。谢谢!

百思不得你姐 2021-11-21 18:04:54

解决方案:在java工程中,新建名为:MANIFEST.MF,打开该文件,加入一下内容:主要作用就是指定当该工程打成jar之后的运行主函数以及引入的第三方jar包。

将该java工程打成jar包时,需要注意在第三步骤时选择如图所示:

打包成功之后,将jar包上传至linux下,并在当前目录下信件lib目录,将MANIFEST.MF中引入的jar包全部copy进去。

然后就可以执行jar包了:java -jar kafka_test.jar,如图:

consumer端已成功接收到消息,如:

终于成功了,非常感谢@FrankHui ,对于我学习kafka有很大的帮助,同时期待你更多精彩详细的kafka文章。谢谢!

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文