Search code examples
pythonapache-kafkapykafka

pykafka topics return None

from pykafka import KafkaClient

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

topics = client.topics
print(topics)

the result of topics is a dict with all values are None:

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

how to fix it?

Solution

  • i fix it in py3:

    topic = client.topics[b'test']

    client.topics don't return a available dict bescause the weak references