kafka源码导入idea

必备工具

• Win10
• Jdk1.8
• Zookeeper-3.4.10
• Scala- 2.12.5
• Gradle 3.3

• kafka-0.10.1.0-src

  准备以上环境请自行百度^-^，接下来就开始让我们用idea编译（ps：我用Gradle命令编译源码，然后再导入idea没有成功）。

  idea配置环境

• idea配置Scala环境：如图
  
  由于我是装了scala的我就不卸载了。
• idea配置Gradle环境。如图
  

配置kafka参数

点击edit configuritions进行参数编写启动参数

配置好以后那么启动zookeeper，然后启动kafka。
ps：网上都写的 Use classpath of moudule：core，但是实际情况配置成core会报错。配置成core_main完美解决。

最后检验kafka是否启动成功

直接贴官方文档 只要把.sh改成.bat就可以了。
下面为测试kafka是否通过的脚本：

1. kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
2. kafka-topics.bat –list –zookeeper localhost:2181
3. kafka-console-producer.bat –broker-list localhost:9092 –topic test
4. kafka-console-consumer.bat –bootstrap-server localhost:9092 –topic test –from-beginning
   然后我们就可以在producer的窗口输入信息，然后观察consumer的窗口是否有接受到消息。如果接受到消息，那么恭喜调试源码程序完美运行了。