python - pykafka 主题返回无

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 不返回可用的字典，因为弱引用

Answer 2

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