Kann ich eine RDD von einem Kafka-Thema erstellen, wenn ich den Bis-Offset nicht kenne?
KafkaUtils.createRDD nimmt die offsetRanges als Parameter. Ich kenne den Zeitversatz des Themas, von dem ich lesen möchte, nicht. Ich möchte höchstens die ersten 30 Nachrichten im Thema lesen.
Ich sehe da ist ein KafkaCluster.html # getLatestLeaderOffsets aber das wird als Entwicklungs-API kommentiert.
ibt es eine öffentliche Möglichkeit, die frühesten und neuesten Offsets für ein Thema zu ermittel