19.kafka---springboot---mongodb

1.效果

 

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

 

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

http://www.javashuo.com/article/p-knhajowl-bx.html

 

3.整合MongoDB到消费者

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

 

引入pom

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

 

 

 

4.源码

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