一行代碼引起的"血案"

昨天在使用pykafka的時候又遇到了以前我遇到過的PartitionOwnedError、ConsumerStoppedException異常，關於這個異常我以前寫過一篇分析的文章(連接在這裏)，我自認爲以前應該是把這個問題完全解決了的，可是此次它又幽靈般的出現了，使我百思不得其解。 1、問題的出現 我在多臺機器上面同時開啓了多個進程來讀寫同一個topic，這個topic有5個partition

>>阅读原文<<