pykafka 主题返回无

Question

from pykafka import KafkaClient

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

topics = client.topics
print(topics)

topics的结果是一个dict，所有的值都是None：

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

如何解决？

Answer 1

我在 py3 中修复它：

topic = client.topics[b'test']

client.topics 不返回可用的字典，因为弱引用

Answer 2

请参阅this GitHub issue，了解为什么会发生这种情况。这不是错误，只是 PyKafka 使用对 Topic 实例的弱引用的奇怪副产品。