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}如何修复？
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}如何修复？
2条答案
按热度按时间axzmvihb1#
有关为什么会发生这种情况的概述，请参阅此github问题。这不是一个bug，只是皮Kafka使用弱引用的一个奇怪的副产品
Topic示例。egmofgnx2#
我在py3中修复它：
client.topics不返回可用的dict，因为引用较弱