Kafka API，用于获取分区和偏移量等主题详细信息

Question

我们有Node，Java应用程序使用Kafka客户端。

当前

要求是获取给定主题的每个分区的当前偏移量。

我们能够在 Confluent 控制中心查看详细信息，并且需要获取该信息以显示在我们的应用程序中。

Answer 1

您可以调用 KafkaConsumer.endOffsets(Collection<TopicPartition> partitions) 来获取给定主题的给定分区的结束偏移量。