docs: function(params, cb) {
      var correlationId = _cbt.put(fetchResponse(cb));
      var msg = envelope(fech.encode()
                             .correlation(correlationId)
                             .client(_options.clientId)
                             .maxWait(params.maxWait)
                             .minBytes(params.minBytes)
                             .topic(params.topic)
                             .partition(params.partition)
                             .offset(params.offset)
                             .maxBytes(_options.maxBytes)
                             .end());
      sendMsg(msg, correlationId, cb);
    }