python-3.x - 如何在使用 kafka-python 消费之前获取 kafka 主题的未消费消息计数？

Question

我正在尝试将 Kafka 消息发布到 API，但仅当主题有新的（未使用的）消息时，我需要知道未使用的消息的数量。有什么方法可以在 Kafka-python 中做到这一点吗？