Kafka Agent 設計 - 可靠事件記錄不是一件簡單的事情

用 golang 編寫，解決事件快速同時可靠入Kafka的問題。綠色表示goroutine（可能是不同的線程），藍色表示共享的資源。所有對藍色資源的訪問需要加鎖。磁盤隊列使用內存映射文件實現ring buffer。kafka agent啓動的時候有一個bootstrap的broker列表，同時發送的時候會與每個相關的broker維護一個到多個連接。但是kafka agent不讀取也不監聽zooke

>>阅读原文<<