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