- fix write Command deadlock
- Added drainAndJoinAwait for consumer stop to handle deadlock scenario related to NSQ message timeout
- Optionally return connection errors for producer requests
- Add producer StopWithDrain
- Deprecate segment/nsq Docker image
- Remove dependency on github.com/segmentio/services
- Drain in-flight messages on close
- Added support for setting msg_timeout in Identify command