生产者丢失数据https://github.com/dpkp/kafka...根据smalyshev的描述,当生产者循环提交消息时,如果kafka宕机,submit不会报错,会继续提交,但是kafka一直宕机,不会接受消息,但是kafka-python这件事不会报错,还是会提交,如果有则丢弃它没有提交。..甚至不会有错误信息。从程序员的角度,我们不知道消息提交成功还是失败。我们不知道消费者是否丢失了数据。这里说的consumerlostdata不是那种,而是因为kafka-pythonbug导致的Dataloss。https://www.infoq.cn/article/...大概意思是kafka-python的迭代机制有问题,会导致获取到的数据在消费前就消失了
