Hi guys,

I'm having a hard time trying to figure out why my Samza job does not start
processing Kafka messages from the last checkpoint.

I have the task configured as

systems.kafka.consumer.auto.offset.reset=smallest
streams.topic-name.consumer.reset.offset=false

However, when the job runs it doesn't start processing anything from the
current offset, just the upcoming messages.

I stop the job, load some messages into the topic and start the job again.
Nothing happens, just the new messages are processed.

Is there anything I am missing here?

I do not want to start processing from the beginning of the topic, just to
make it clear. I want to process from the last checkpoint.


Thanks,

- Claudio Martins
linkedin: www.linkedin.com/in/martinsclaudio

Reply via email to