本文介紹如何將雲訊息佇列 Kafka 版接入Logstash。
Logstash
Logstash是開源的伺服器端資料處理管道，能夠同時從多個資料來源採集資料，然後對資料進行轉換，並將資料寫入指定的儲存中。Logstash的資料處理流程如下：
輸入：採集各種格式、大小和來源的資料。在實際業務中，資料往往以各種各樣的形式分散或集中地儲存在多個系統中，Logstash支援多種資料輸入方式，可以在同一時間從多種資料來源採集資料。Logstash能夠以連續的串流方式從日誌、Web應用、資料存放區等採集資料。
過濾：即時解析和轉換資料。資料從源傳輸到目標儲存的過程中，Logstash過濾器能夠解析各個事件，識別已命名的欄位來構建結構，並將它們轉換成通用格式，通過更輕鬆、快速的方式分析資料來實現商業價值。
輸出：匯出資料。Logstash提供多種資料輸出方向，靈活解鎖眾多下遊用例。
更多關於Logstash的介紹，請參見Logstash簡介。
接入優勢
雲訊息佇列 Kafka 版接入Logstash可以帶來以下優勢：
非同步處理：提高運行效率，防止突發流量影響使用者體驗。
應用解耦：當應用上下遊中有一方存在異常情況，另一方仍能正常運行。
減少開銷：減少Logstash的資源開銷。
接入方案
雲訊息佇列 Kafka 版支援以下方式接入Logstash：