KafkaSocket.prototype.getMessageTime = function(json) {
    // Default to extracting time from wrapped payload
    if (null != json && null != json.wrappedPayload && null != json.wrappedPayload.p) {
        var time = json.wrappedPayload.p.time;
        logger.debug('%s: Extracted message time of %d', this.name, time);