from pykafka import KafkaClient,common
client = KafkaClient(hosts="192.168.127.108:9092") #实例化
print(client.topics)
print(client.brokers)
微信扫一扫
from pykafka import KafkaClient,common
client = KafkaClient(hosts="192.168.127.108:9092") #实例化
print(client.topics)
print(client.brokers)
相关推荐