lib/karafka/attributes_map.rb in karafka-0.6.0.rc2 vs lib/karafka/attributes_map.rb in karafka-1.0.0.rc1
- old
+ new
@@ -31,16 +31,15 @@
end
# @return [Array<Symbol>] properties that can be set on a per topic level
def topic
(config_adapter[:subscription] + %i[
- processing_backend
+ backend
name
- worker
parser
- interchanger
responder
batch_processing
+ persistent
]).uniq
end
# @return [Array<Symbol>] properties that can be set on a per consumer group level
# @note Note that there are settings directly extracted from the config kafka namespace