reportLatestOffset

Retorna o deslocamento mais recente disponível.

A informação é usada para reportar o último deslocamento no status da consulta de transmissão. A fonte pode retornar None se não houver dados para processar ou se a fonte não suportar este método.

Sintaxe

reportLatestOffset()

Devoluções

dict ou None

Um dicionário ou dicionário recursivo cuja key e valor são tipos primitivos, incluindo Integer, strings e Boolean. Retorna None se a fonte não suportar o reporte do deslocamento mais recente.

Exemplos

Python

def reportLatestOffset(self):
    return {"partition-1": {"index": 100}, "partition-2": {"index": 200}}