lib/karafka/attributes_map.rb in karafka-1.1.0.alpha1 vs lib/karafka/attributes_map.rb in karafka-1.1.0.alpha2

- old
+ new

@@ -19,15 +19,15 @@ consumer: %i[ session_timeout offset_commit_interval offset_commit_threshold offset_retention_time heartbeat_interval ], subscription: %i[start_from_beginning max_bytes_per_partition], - consuming: %i[min_bytes max_wait_time automatically_mark_as_processed], + consuming: %i[min_bytes max_wait_time], pausing: %i[pause_timeout], # All the options that are under kafka config namespace, but are not used # directly with kafka api, but from the Karafka user perspective, they are # still related to kafka. They should not be proxied anywhere - ignored: %i[reconnect_timeout] + ignored: %i[reconnect_timeout automatically_mark_as_consumed] } end # @return [Array<Symbol>] properties that can be set on a per topic level def topic