kafak-python函数使用详解

Consumer是非线程安全的 Kafka只保证消息不漏，即at lease once，而不保证消息不重。关键点：假如consumer挂了重启，那它将从committed offset ...