需要一個簡單的多線程水槽源

Question

尋找諮詢如何建立一個簡單的多線程水槽源。

我一直在使用spoolDir源在我的本地開發環境中測試我的攔截，但是從下面的鏈接，它看起來像spoolDir來源永遠是單線程：

Reading Flume spoolDir in parallel

我們有一個攔截器，可能是生產中的錯誤，因爲它使用非線程安全的SimpleDateFormatter，我試圖在我簡單的開發環境中重現。

Answer 1

我最終能夠通過從spoolDir源到syslogtcp源切換我的開發環境重現，我們在生產中看到的多線程錯誤行爲。這個bug並不是我們所期望的，它與SimpleDateFormatter無關，而是它如何在事件頭中插入其他信息。

我通過使用nc（netcat）將數據發送到系統日誌端口來模擬系統日誌服務器。我通過記錄線程名稱和ID來驗證攔截器被多個線程調用。

因此對於任何感興趣的人來說，最好使用像syslogtcp這樣的多線程源而不是spoolDir源來測試你的攔截器。