Кафка не работает таким образом. Вы видите Kafka как нечто, что вы можете запросить с другим параметром, отличным от смещения, кроме того, имейте в виду, что тема может иметь более одного раздела, поэтому каждый раздел имеет свой раздел. Возможно, вы можете использовать другое реляционное хранилище для отображения смещения / раздела с отметкой времени, что немного рискованно. Думая, например, о потребителе akka stream kafka, каждый ваш запрос по метке времени должен отправляться через другую тему, чтобы активировать ваших потребителей (каждому из которых назначается один или несколько разделов) и запрашивать конкретное смещение, результат и слияние. С Spark вы можете настроить свои потребительские стратегии для каждой работы, но процесс должен быть таким же.
Другое дело, если ваш Кафка восстанавливает, возможно, вам нужно прочитать всю тему, чтобы обновить свою пару (временная метка / смещение). Все это может звучать немного странно, и, может быть, лучше сохранить свою тему в Кассандре (например), и вы можете запросить ее позже.