## nothin! use default source labels
        end
  
 +      if Time.now - last_info_time > PROGRESS_UPDATE_INTERVAL
 +        last_info_time = Time.now
 +        elapsed = last_info_time - start_time
 +        pctdone = source.respond_to?(:pct_done) ? source.pct_done : 100.0 * (source.cur_offset.to_f - source.start_offset).to_f / (source.end_offset - source.start_offset).to_f
 +        remaining = (100.0 - pctdone) * (elapsed.to_f / pctdone)
 +        $stderr.printf "## read %dm (about %.0f%%) @ %.1fm/s. %s elapsed, about %s remaining\n", num_scanned, pctdone, num_scanned / elapsed, elapsed.to_time_s, remaining.to_time_s
 +      end
 +
        if index_state.nil?
-         puts "Adding message #{source}##{offset} with state {#{m.labels * ', '}}" if opts[:verbose]
+         puts "Adding message #{source}##{offset} from #{m.from} with state {#{m.labels * ', '}}" if opts[:verbose]
          num_added += 1
        else
          puts "Updating message #{source}##{offset}, source #{entry[:source_id]} => #{source.id}, offset #{entry[:source_info]} => #{offset}, state {#{index_state * ', '}} => {#{m.labels * ', '}}" if opts[:verbose]