Flume 讀取RabbitMq消息隊列消息,並將消息寫入kafka

首先是關於flume的基礎介紹 組件名稱     功能介紹 Agent代理 使用JVM 運行Flume。每臺機器運行一個agent,但是可以在一個agent中包含多個sources和sinks。 Client客戶端 生產數據,運行在一個獨立的線程。 Source源 從Client收集數據,傳遞給Channel。 Sink接收器 從Channel收集數據,進行相關操作,運行在一個獨立線程。 Chan
相關文章
相關標籤/搜索