- Consumer的非线程安全
- Kafka只保证消息不漏，即at lease once，而不保证消息不重。关键点：假如consumer挂了重启，那它将从committed offset位置(告诉server的消费的位置点)开始重新消费，而不是consume offset位置(真正的消费位置点)。这也就意味着有可能重复消费(自己消费到了某个位置，而后在告诉服务器这个位置时，发送失败)Kafka只保证消息不漏，即at lease
阅读背景：
kafak-python函数使用详解
来源：互联网
分享到：
