網易雲課堂學習-kafka streams架構

程序重啓後纔會從服務端拿offset，來決定從哪裏消費。 客戶端會維護一個partition_id和offset，以此知道下次從哪裏開始拉取。 批處理計算： 會有一定的延時，只能查到昨天的數據 Spark和Flink既能做批處理，又能做流處理 pageCache：操作系統的內存 kafka寫性能高的原因：1.用了pageCache 2.使用了順序寫 通過mapped memory file技術將數

>>阅读原文<<