spring-boot整合spring-kafka发送接收消息

由于我们的新项目使用的是spring-boot,而又要同步新项目中建的数据到老的系统当中.原来已经有一部分的同步代码,使用的是kafka. 其实只是做数据的同步,我觉得选MQ没必要使用kafka.首先数据量不大,其实搞kafka又要搞集群,ZK.只是用做一些简单数据同步的话,有点大材小用.

没办法,咱只是个打工的,领导让搞就搞吧.刚开始的时候发现有一个spring-integration-kafka,描述中说是基于spring-kafka做了一次重写.但是我看了官方文档.实在是搞的有点头大.功能一直没实现.文档写的也不是很漂亮,也可能是刚起步,有很多的问题.我这里只能放弃了,使用了spring-kafka.

pom.xml文件如下

orm层使用了MyBatis,又使用了通用Mapper和分页插件.

kafka消费端配置

生产者的配置.

监听,监听里面,写的就是业务逻辑了,从kafka里面得到数据后,具体怎么去处理. 如果需要开启kafka处理消息的广播模式,多个监听要监听不同的group,即方法上的注解@KafkaListener里的group一定要不一样.如果多个监听里的group写的一样,就会造成只有一个监听能处理其中的消息,另外监听就不能处理消息了.也即是kafka的分布式消息处理方式.

在同一个group里的监听,共同处理接收到的消息,会根据一定的算法来处理.如果不在一个组,但是监听的是同一个topic的话,就会形成广播模式

 

  11 comments for “spring-boot整合spring-kafka发送接收消息

  1. jean
    2017 年 1 月 13 日 at 10:59

    能否源码分享一下,学习呢

  2. cricket
    2017 年 1 月 5 日 at 21:42

    源码的github地址是?

  3. 云逸云飞
    2016 年 12 月 16 日 at 10:35

    你好,我像你一样的配置的,但是使用@KafkaListener注解,监听不到消息,不知道什么原因,

  4. lixiaowei
    2016 年 12 月 15 日 at 10:25

    github 地址多少

  5. xiaoy
    2016 年 11 月 2 日 at 08:57

    生产者的调用代码在哪里,还有
    import org.linuxsogood.qilian.enums.CupMessageType;
    import org.linuxsogood.qilian.kafka.MessageWrapper;
    import org.linuxsogood.qilian.model.store.Store;
    import org.linuxsogood.sync.mapper.StoreMapper;
    import org.linuxsogood.sync.model.StoreExample;
    这几个类都是你自己的吧 能否共享了。
    最好有一个测试代码,能让我们这些初学者快点上手,很期待你能给点技术帮助,能把QQ或微信号共享了么

发表评论

电子邮件地址不会被公开。 必填项已用*标注

Captcha Code