Python-Kakfa手动维护offset

“生产者，消费者，offset。”

kafka: 2.11-0.10.2.1

python-kafka: 1.3.5

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

01

生产者

02

消费者

03

手动维护offset

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