helloworld.zh_CN - adyliu/jafka GitHub Wiki
文档>>Hello World
#Hello world启动服务端(Broker)参考安装指南.
Python 客户端入门
###发送消息
import jafka
producer = jafka.Producer('127.0.0.1',9092)
producer.send(topic='demo',messages='Hello jafka')
producer.send('demo',('Try it','Jafka is simple'))
producer.send('demo',('Try it','Jafka is simple'),2)
producer.close()
###消费消息
import jafka
import time
consumer = jafka.Consumer('127.0.0.1',9092)
offset = 0
while True:
messages = consumer.fetch('demo',0,offset)
if not messages:
time.sleep(1)
continue
for offsetmessage in messages:
offset,message = offsetmessage
print(offset,' => ',message.decode())
Language: English | Simple Chinese