3、构建产生idea 源码工程文件
在项目根目录下执行命令:gradle idea 源码
编译完成后出现工程文件
臸此kafka环境搭建好了,如果还有不明白可以看看参考文章
文章会同步到公众号,关注公众号交流更方便:
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模式启动消费者在控制台可以看到有消息被消费:
版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。