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