KafkaSocket.prototype.ignorePayload = function(rawMessage, json, consumer) {
    // Ignore any payloads that are too old.
    if (null != ignoreOlderThan) {
        var now = Date.now();
        var messageTime = this.getMessageTime(json);