#676·faust

consumer_auto_offset_reset="latest" doesn't work

Author: Azrrael-exeCreated Oct 22, 2020Updated Sep 22, 2023

Checklist

  • I have included information about relevant versions
  • I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

I am trying to develop a stream processor that doesn't require the previous messages using the offset.

app = faust.App(
    id=settings.APP,
    autodiscover=True,
    origin="app",
    broker="kafka://localhost:9092",
    value_serializer="raw",
    enable_sensors=True,
    enable_web=True,
    consumer_auto_offset_reset="latest"
)

Expected behavior

Ignore the previous unprocessed messages.

Actual behavior

Proccess the whole history of the topic

Full traceback

N/A

Versions