在Apache Kafka主题中获取消息数量

Apache Kafka是一个开源的分布式事件流平台。

在这个快速教程中，我们将学习获取Kafka主题中消息数量的技术。我们将展示程序化以及原生命令技术。

2. 程序化技术

Kafka主题可能有多个分区。我们的技术应该确保我们计算了每个分区中的消息数量。

**我们必须逐个检查每个分区的最新偏移量。**为此，我们将引入一个消费者：

KafkaConsumer``<String, String>`` consumer = new KafkaConsumer``<String, String>``(props);