lib/kafka-consumer-stream.js
function retry() {
    if (!self.waitInterval) {
      setImmediate(function() {
        self._read(size);
      });
    } else {
      setTimeout(function() {
        self._read(size);
      }, self.waitInterval * Math.random()).unref();
    }
  }
function retry() {
    if (!self.waitInterval) {
      setImmediate(function() {
        self._read(size);
      });
    } else {
      setTimeout(function() {
        self._read(size);
      }, self.waitInterval * Math.random()).unref();
    }
  }
function retry ( ) { if ( ! self . waitInterval ) { setImmediate ( function ( ) { self . _read ( size ) ; } ) ; } else { setTimeout ( function ( ) { self . _read ( size ) ; } , self . waitInterval * Math . random ( ) ) . unref ( ) ; } }
Retry function. Will wait up to the wait interval, with some random noise if one is provided. Otherwise, will go immediately.
Retry function . Will wait up to the wait interval with some random noise if one is provided . Otherwise will go immediately .