The kafka output stores offsets whenever an event is stored.
However, writing into kafka is asynchroneous and there is no feed-back in Logprep if writing was actually successful.
Thus, it can happen that an offset is set before an event was really written into kafka.

It would be desireable if offsets are only set for events that were successfully sent.
Otherwise there is a possibility for data loss.

A possible solution could involve using a callback in the produce method:
https://docs.confluent.io/kafka-clients/python/current/overview.html#asynchronous-writes