lib/karafka/connection/config_adapter.rb in karafka-1.1.0.alpha1 vs lib/karafka/connection/config_adapter.rb in karafka-1.1.0.alpha2

@@ -49,10 +49,13 @@
         #   consume_each_message methods
         # @param consumer_group [Karafka::Routing::ConsumerGroup] consumer group details
         # @return [Hash] hash with all the settings required by
         #   Kafka::Consumer#consume_each_message and Kafka::Consumer#consume_each_batch method
         def consuming(consumer_group)
-          sanitize(fetch_for(:consuming, consumer_group))
+          settings = {
+            automatically_mark_as_processed: consumer_group.automatically_mark_as_consumed
+          }
+          sanitize(fetch_for(:consuming, consumer_group, settings))
         end
 
         # Builds all the configuration settings for kafka consumer#subscribe method
         # @param topic [Karafka::Routing::Topic] topic that holds details for a given subscription
         # @return [Hash] hash with all the settings required by kafka consumer#subscribe method