1.效果

当用户发送一条消息===》kafka生产者===》kafka消费者====》插入到MongoDB

2. kafka生产者与消费者搭建

https://my.oschina.net/u/4132381/blog/3064078

3.整合MongoDB到消费者

#连接MongoDB
spring.data.mongodb.host=127.0.0.1
spring.data.mongodb.port=27017
spring.data.mongodb.database=mongodb_table

19.kafka---springboot---mongodb-LMLPHP

引入pom

<!--5.MongoDB-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

19.kafka---springboot---mongodb-LMLPHP

19.kafka---springboot---mongodb-LMLPHP

19.kafka---springboot---mongodb-LMLPHP

4.源码

链接:https://pan.baidu.com/s/1MnvBOSlw2Phd6qsi1TzzTw 
提取码:9lkm 

06-30 15:16