“生产者,消费者,offset。”
kafka: 2.11-0.10.2.1
python-kafka: 1.3.5
Kafka是什么,是读卡夫卡还是卡法卡?有维基百科在,这里就不多做介绍了。
01
生产者
02
消费者
03
手动维护offset
对于消费者程序,重启是再正常不过的事情了,比如进程内存占用过大被Linux系统给杀掉了。如果消费者程序重启,但是生产者还在不停发发数据,这就会导致数据丢失,这里就需要手动维护偏移量offset了。
分享快讯到朋友圈
领取专属 10元无门槛券
私享最新 技术干货