modified:   ../consumer/log_source_manager.go