Continuing the discussion from Alpakka Kafka connector in Akka Streams:
In case of an error in sources emitted from
the docs says that the
subSource is re-emitted and seeked to last committed offset.
However, in the implementation, it looks like we are seeking to the last not
So, in case of any errors, this can cause data loss.