必备工具
配置kafka参数
点击edit configuritions进行参数编写启动参数
配置好以后那么启动zookeeper,然后启动kafka。
ps:网上都写的 Use classpath of moudule:core,但是实际情况配置成core会报错。配置成core_main完美解决。
最后检验kafka是否启动成功
直接贴官方文档 只要把.sh改成.bat就可以了。
下面为测试kafka是否通过的脚本:
- kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
- kafka-topics.bat –list –zookeeper localhost:2181
- kafka-console-producer.bat –broker-list localhost:9092 –topic test
- kafka-console-consumer.bat –bootstrap-server localhost:9092 –topic test –from-beginning 然后我们就可以在producer的窗口输入信息,然后观察consumer的窗口是否有接受到消息。如果接受到消息,那么恭喜调试源码程序完美运行了。