lib/api.js
function(params, cb) {
    var correlationId = _cbt.put(offsetResponse(cb));
    var msg = envelope(off.encode()
                          .correlation(correlationId)
                          .client(_options.clientId)
                          .replica()
                          .topic(params.topic)
                          .partition(params.partition)
                          .timestamp()
                          .maxOffsets()
                          .end());
    sendMsg(msg, correlationId, cb);
  }
function(params, cb) {
    var correlationId = _cbt.put(offsetResponse(cb));
    var msg = envelope(off.encode()
                          .correlation(correlationId)
                          .client(_options.clientId)
                          .replica()
                          .topic(params.topic)
                          .partition(params.partition)
                          .timestamp()
                          .maxOffsets()
                          .end());
    sendMsg(msg, correlationId, cb);
  }
function ( params , cb ) { var correlationId = _cbt . put ( offsetResponse ( cb ) ) ; var msg = envelope ( off . encode ( ) . correlation ( correlationId ) . client ( _options . clientId ) . replica ( ) . topic ( params . topic ) . partition ( params . partition ) . timestamp ( ) . maxOffsets ( ) . end ( ) ) ; sendMsg ( msg , correlationId , cb ) ; }
request the latest offset from kafka

i.e. the OLD offset api, not commit / fetch
request the latest offset from kafka