pykafka 主题 return None

Question

from pykafka import KafkaClient

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

topics = client.topics
print(topics)

topics 的结果是一个字典，所有值都是 None:

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

如何解决？

Answer 1

我在 py3 中修复它：

topic = client.topics[b'test']

client.topics 不要 return 可用的字典，因为引用较弱

Answer 2

有关发生这种情况的原因的概述，请参阅 this GitHub issue。这不是错误，只是 PyKafka 使用对 Topic 个实例的弱引用的奇怪副产品。