一行代碼引起的"血案"

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