diff --git a/lib/searchkick/process_queue_job.rb b/lib/searchkick/process_queue_job.rb
index fd6e688..655d987 100644
--- a/lib/searchkick/process_queue_job.rb
+++ b/lib/searchkick/process_queue_job.rb
@@ -5,7 +5,7 @@ module Searchkick
     def perform(class_name:)
       model = class_name.constantize
 
-      limit = 1000
+      limit = model.searchkick_index.options[:batch_size] || 1000
       record_ids = Searchkick::ReindexQueue.new(model.searchkick_index.name).reserve(limit: limit)
       if record_ids.any?
         Searchkick::ProcessBatchJob.perform_later(
--
libgit2 0.21.0