KafkaMonitor 源码导入 idea 源码怎么启动?查看页面

版权声明:本文为博主原创文章遵循 版权协议,转载请附上原文出处链接和本声明

3、构建产生idea 源码工程文件
在项目根目录下执行命令:gradle idea 源码

编译完成后出现工程文件

臸此kafka环境搭建好了,如果还有不明白可以看看参考文章

文章会同步到公众号,关注公众号交流更方便:

}

 kafka源码环境搭建好之后需要在IntelliJ idea 源碼开发工具中以debug方式启动kafka服务器来测试消息的生产和消费。

 

大概意思是说kafka-0.10.0.1-src这个模块的编译输出目录有问题需要为production和tests指定不同的编译输出目录。

1.首先指定project的编译输出目录:

再次在idea 源码中启动kafka服务器会看到scalac开始编译:

配置生产者(ConsoleProducer,它里面也有一个main方法启动该main方法就相当於启动了一个kafka生产者)启动参数(在Program arguments中可以给生产者传递启动参数):

配置消费者(ConsoleConsumer,它里面也有一个main方法启动这个main方法就相当于启动叻一个消费者)启动参数(在Program arguments中可以给消费者传递启动参数):

以debug方法启动kafka服务器成功:

以debug方式启动生产者成功,可以在控制台输入消息并回车,就可以向kafka服务器发送消息:

同样以debug模式启动消费者在控制台可以看到有消息被消费:

}

我要回帖

更多关于 idea 源码 的文章

更多推荐

版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。

点击添加站长微信