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 !!!
更多文章
-
i3wm dmenu的优秀替代品 rofi 窗口切换/搜索
2018-07-23-23:11rofi https://github.com/DaveDavenport/rofi/ 效果- -还不错 速度很快 比gnome-do之类的要爽的多 上配置文件 bindsym $mod+d exec --no-startup-id
-
windows 2019 ltsb(ltsc) 支持了 wsl 完美!
2018-11-13-21:09下载地址 Ubuntu 18.04 Ubuntu 18.04 ARM Ubuntu 16.04 Debian GNU/Linux Kali Linux OpenSUSE SLES 用管理员权限 打开powershell 不得不说 现