lib/karafka/attributes_map.rb in karafka-1.2.3 vs lib/karafka/attributes_map.rb in karafka-1.2.4

@@ -16,10 +16,10 @@
       # @return [Hash] hash with proper sections on what to proxy where in Ruby-Kafka
       def api_adapter
         {
           consumer: %i[
             session_timeout offset_commit_interval offset_commit_threshold
-            offset_retention_time heartbeat_interval
+            offset_retention_time heartbeat_interval fetcher_max_queue_size
           ],
           subscribe: %i[start_from_beginning max_bytes_per_partition],
           consumption: %i[min_bytes max_bytes max_wait_time],
           pause: %i[pause_timeout],
           # All the options that are under kafka config namespace, but are not used