modified:   consumer/client/flume_client.go