kafka作為消息中間件的一款產品，她比較輕量級，在吞吐量方面很優秀，默認消息持久化到硬盤當中 168小時=7天，log.retention.hours=168，比較適合來做運營的統計。其他的不多講，先看看pom依賴吧
這里我使用的版本為：
kafka.version=2.2.0.RELEASE
kafka-client.version=2.0.0
|| 消息提供方
消息提供者的application.properties配置（接口層）：
消息提供者發送消息：
|| 消息消費方
消息消費者者的application.properties配置（服務層）：
監聽消息：
Kafka消息測試：
狂點幾下請求接口后，查看redis緩存情況：
大家不難看到，我使用Kafka對搜索的商品次數做了統計（僅僅是測試代碼）。先在接口層，每請求一個商品查詢接口，就把查詢的商品ID發送到Kafka消息隊列，再在服務層監聽統計查詢次數。
到現在為止，項目的基本配置和一些服務集成接入已經實現，接下來我會更深入的講述項目中經常遇到的坑和怎么防止不跳坑，以及分布式任務調度管理，分布式事務一致性處理等。
獲取項目源代碼，請掃碼關注公眾號，並發送Springboot獲取。
