kafka多消費者處理

它不能像AMQ那樣可以多個BET作爲consumer去互斥的（for update悲觀鎖）併發處理message，這是因爲多個BET去消費一個Queue中的數據的時候，由於要保證不能多個線程拿同一條message，所以就需要行級別悲觀所（for update）,這就導致了consume的性能下降，吞吐量不夠。而kafka爲了保證吞吐量，只允許同一個consumer group下的一個consume

>>阅读原文<<