如何使用kafka-python计算主题中的记录（消息）数量

Question

正如标题中所说，我想在我的主题中获得一些记录，但我找不到使用 kafka-python 库的解决方案。有人有什么主意吗 ？

Answer 1

没有特定的 API 来计算某个主题的记录数。您需要消费并计算从 kafka 消费者收到的记录数。