Currently, InlineConsumer will try to seek to the necessary offset, and if it can't (e.g. LeaderNotAvailable error), it'll just ignore the seek. This may cause integration tests to fail. We should replace this logic with sleep + retries (up to a max of 3), similar to what RubyKafka does in this case.
Currently, InlineConsumer will try to seek to the necessary offset, and if it can't (e.g. LeaderNotAvailable error), it'll just ignore the seek. This may cause integration tests to fail. We should replace this logic with sleep + retries (up to a max of 3), similar to what RubyKafka does in this case.