小编Bal*_*eck的帖子

KafkaUtils.createRDD将offsetRanges作为参数.我不知道我要阅读的主题的偏移量.我想最多阅读主题中的前30条消息.

我看到有一个KafkaCluster.html#getLatestLeaderOffsets,但它被注释为Develop API.

有没有公​​开的方法来确定某个主题的最早和最新补偿？