lib/topological_inventory/sync/host_inventory_response_worker.rb
# No persist_ref here, because all instances (pods) needs to receive kafka message
No persist_ref here, because all instances (pods) needs to receive kafka message
No persist_ref here because all instances ( pods ) needs to receive kafka message
def queue_opts
        opts               = {:service => config.queue_topic}
        opts[:auto_ack]    = config.queue_auto_ack    unless config.queue_auto_ack.nil?
        opts[:max_bytes]   = config.queue_max_bytes   if config.queue_max_bytes
        opts[:persist_ref] = config.queue_persist_ref if config.queue_persist_ref
        opts
      end
def queue_opts opts = { :service => config . queue_topic } opts [ :auto_ack ] = config . queue_auto_ack unless config . queue_auto_ack . nil? opts [ :max_bytes ] = config . queue_max_bytes if config . queue_max_bytes opts [ :persist_ref ] = config . queue_persist_ref if config . queue_persist_ref opts end
No persist_ref here, because all instances (pods) needs to receive kafka message
No persist_ref here because all instances ( pods ) needs to receive kafka message