首页 日常 数据库 仓库 关于我 关于本站

kafka 发布订阅分组

2018-11-28-00:12

惹不起的kafka

启动zookeeper

./zookeeper-server-start.sh ../config/zookeeper.pperties

启动kafka

./kafka-server-start.sh ../config/server.propertis

记得给配置文件配置分区数

代码

发布

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')

if __name__ == '__main__':
    for a in range(1,2):
        producer.send('chat',partition=1,value=b'some_message_bytes')
        producer.flush()

订阅分区

from kafka import KafkaConsumer

if __name__ == '__main__':

    consumer = KafkaConsumer("chat",bootstrap_servers=['localhost:9092'])
    consumer.subscribe(pattern="1")
    for msg in consumer:
        print(msg)

惹不起 惹不起 rabbitMQ 的2500个 队列才3g内存

kafka 一个topic (概念上的队列) 分区(打的tag) 2000个 竟然 需要40g 储存。。。

口区。。。。

我要去试试 nsq !!!

更多文章


<img href="http://res03.meng2u.com/deduct_attachment/program/a40/26/57/tqQSGeQxbZDsZ07u.jpg" />

愿意透露姓名的网友:mandian

Bela retpaĝo. Dankon !!!

愿意透露姓名的网友:JOJO

界面很清爽

愿意透露姓名的网友:哇哦

好久买来逛逛了,七月15日 阴

愿意透露姓名的网友:mandian

PRAGMA journal_mode=wal

愿意透露姓名的网友:admin

友情链接