赞
踩
XML |
在项目的yaml中增加相关依赖信息,如公司业务项目中的
YAML |
简单情境下,直接使用kafka进行测试可以在producer和customer类中写,为求模块化,这里才开使用,合并以及拆开都不影响使用。
Java |
Java |
在producer中,先创建类实现抽象类的方法,便于后续装配
Java |
同理 consumer类中
Java |
标红地方属于自己的业务逻辑。
Java |
启动调用
在启动类application中,必须先 注册消费类,让消费类运行
Java |
最终可以简单写一个test的测试向kafka传递数据,就可以查看数据,并也可以设置断点,查看步骤,like this。
Java |
ok,
原先的公司包中有这些文件abstractProducer,ByteArrayAbstractKafkaConsumer,
Markdown |
我看网上都是使用的spring-kafka来整合整个项目,但是该项目使用的是kafka-clients依赖。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。