kafka消費慢的的一次排錯過程

環境:centos6.5,cdh5.7.1,kafka 0.9.0.1。html 咱們的topic有12個partitions分佈在12個broker,副本數3。用的old higth level API。分別在12臺機器上啓動消費者,每一個都是單線程,因此就是一個consumer消費一個partition。可是呢,消費就是有積壓。apache 解決:嗯,1消費者拉取數據2處理3數據流向下個目的地
相關文章
相關標籤/搜索