pykafka主題返回None

Question

from pykafka import KafkaClient 

client = KafkaClient(hosts='192.168.199.87:9092') 

topics = client.topics 
print(topics) 

主題的結果是所有值的字典都無：

{b'user_name_topic': None, b'test_topic': None} 

如何解決呢？

Answer 1

我解決它在PY3：

topic = client.topics[b'test'] 

client.topics不返回可用字典bescause的弱引用

Answer 2

見this GitHub issue對於爲什麼發生這種情況的概述。這不是一個bug，只是PyKafka使用對Topic實例的弱引用的一個奇怪的副產品。