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实例的弱引用的一个奇怪的副产品。