Python-Kakfa手动维护offset

生产者,消费者,offset。

kafka: 2.11-0.10.2.1

python-kafka: 1.3.5

Kafka是什么,是读卡夫卡还是卡法卡?有维基百科在,这里就不多做介绍了。

01

生产者

02

消费者

03

手动维护offset

对于消费者程序,重启是再正常不过的事情了,比如进程内存占用过大被Linux系统给杀掉了。如果消费者程序重启,但是生产者还在不停发发数据,这就会导致数据丢失,这里就需要手动维护偏移量offset了。

  • 发表于:
  • 原文链接:http://kuaibao.qq.com/s/20180123G02XRL00?refer=cp_1026

相关快讯

扫码关注云+社区