lib/karafka/attributes_map.rb in karafka-1.3.0.rc1 vs lib/karafka/attributes_map.rb in karafka-1.3.0
- old
+ new
@@ -9,12 +9,12 @@
# setting it and sending it forward
# @note Settings presented here cover all the settings that are being used across Karafka
module AttributesMap
class << self
# What settings should go where in ruby-kafka
+ # @return [Hash] hash with proper sections on what to proxy where in Ruby-Kafka
# @note All other settings will be passed to Kafka.new method invocation.
# All elements in this hash are just edge cases
- # @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 fetcher_max_queue_size