修改连接泄露的问题
	modified:   consumer/log_sink.go