test server: Mutex replaced with RWMutex
test server: Mutex replaced with RWMutex

taheris/kafka,zorkian/kafka,alexcesaro/kafka,legionus/kafka,dropbox/kafka,zorkian/kafka,alexcesaro/kafka,optiopay/kafka,danieltahara/kafka,liftoffio/go-kafka,husio/kafka,taheris/kafka,optiopay/kafka,dropbox/kafka,husio/kafka,liftoffio/go-kafka,legionus/kafka,danieltahara/kafka