replace errors.New() with fmt.Errorf();  better info in log message
replace errors.New() with fmt.Errorf();  better info in log message

ChrisLundquist/kafka,quipo/kafka-go,jdamick/kafka,yonglehou/kafka