springboot-kafka一個簡單例子

1、引入springboot-kafka的jar包依賴。 2、在application.properties添加配置信息，本機安裝的kafka的ip和端口號，9092默認端口。消費者的組名稱。 3、創建生產者服務，聲明成spring組件，注入KafkaTemplate，send方法的第一個參數是topic的名稱，第二個參數是數據。 4、創建消費者服務，開啓監聽，如果獲取到數據，則輸出接受到的數據。

>>阅读原文<<