小编ugo*_*ria的帖子

我正在使用kafka-python来使用来自 kafka 队列（kafka 版本 0.10.2.0）的消息。特别是我使用的是KafkaConsumer类型。如果消费者停止并在一段时间后重新启动，我想从最新生成的消息重新启动，即删除消费者关闭期间生成的所有消息。我怎样才能做到这一点？

谢谢