from pykafka import KafkaClient client = KafkaClient(hosts ="127.0.0.1:9092") #可接受多个client #查看所有的topic topic = client.topics[b'test'] print(topic) #选择一个topic message ="test message test message" #生产kafka数据,通过字符串形式 producer=topic.get_producer() producer.produce(b'message') print (message)
因为kafka在传输的时候需要bytes,而不是str,所以在str上加上b标识