modified:   consumer/log_source.go
	modified:   consumer/log_source_manager.go