En lugar de usar earliest, se usa latest, para en caso de perder el offset, no reprocesar información.
mentioned in commit 5799ef68