python - 我怎么能模仿 Kafka 消费者错过在 Python 中消费一条消息

有没有一种优雅的方法来测试这个 - 我有一个 Kafka Broker 设置了两个分区，并且有一个生产者发布到两个分区（随机）。我有两个消费者在线程之间运行随机睡眠，一个设置为最早自动偏移，另一个设置为最新。

我试图模仿一个场景，当消费者设置为最新时会错过生产者发送的消息。如果发生这种情况，是否有办法强制第二个消费者（最早的）接收错过的特定消息，而不是使用最新的消息？和/或第一个消费者（而不是被重新启动）可以被迫找到它错过的偏移量？

标签： pythonapache-kafkakafka-consumer-api