用于获取主题详细信息的 Kafka API，例如 Partition 和 Offset

Question

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

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

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

Answer 1

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