SpringBoot整合kafka，以及多播機制的應用

最近做一個需求需要用SpringBoot整合Kafka的多播機制，所以就順便寫篇文章介紹一下自己的對Kafka多播機制的應用吧。 先說明一下我的需求，一個分佈式系統內每個節點需要處理存在該節點本地的文件，但是處理的任務必須放到隊列中排隊避免高併發引起的系統崩潰。當時由於需要處理的文件都是在發出消息的節點上的，所以考慮之後決定使用Kafka的多播機制來實現。 首先簡單講解一下Kafka的多播機制。K

>>阅读原文<<