天天看點

Docker搭建Kafka

下載下傳Kafka和Zookeeper鏡像檔案

先運作zk,再運作kafka

建立主題

Docker搭建Kafka

 在項目代碼我們可以進行AOP日志處理,将異常資訊 發送到Kafaka 然後 Logstash訂閱話題,将資料寫入到ES中。

Logstash配置:  通過Logstash去訂閱主題,主題要保持一緻與代碼,與建立的主題。

啟動Logstash: ./bin/logstash -f  goods_mylog.conf