Add generator change

tap_mambu/tap_generators/multithreaded_offset_generator.py

@@ -132,7 +132,7 @@ def _all_fetch_batch_steps(self):
             final_buffer = []
             while start < end:
                 # Limit the buffer size by holding generators from creating new batches
-                while len(self.buffer) > 100000:
+                while len(self.buffer) > self.max_buffer_size:
                     time.sleep(1)
                 self.modify_request_params(start, temp)
                 final_buffer, stop_iteration = self.collect_batches(self.queue_batches())