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

Question

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

标签： pythonapache-kafkakafka-python

Answer 1

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