SinkConfig.js message value null

[vuongwphamj]

class SinkConfig

static _messageToRecord(message) {

        //check if a converter has already turned this message into a record
        if (message && typeof message.value === "object" &&
            message instanceof SinkRecord) {
            return message;
        }

        try {
            const record = new SinkRecord();

            record.kafkaOffset = message.offset;
            record.key = message.key;
            record.partition = message.partition;

            record.keySchema = message.value.keySchema;
            record.timestamp = message.value.timestamp;
            record.value = message.value.value;
            record.valueSchema = message.value.valueSchema;

            return record;
        } catch (error) {
            debug("Failed to turn message into sink record.", error.message);
            super.emit("error", "Failed to turn message into SinkRecord: " + error.message);
            return message;
        }
    }

[vuongwphamj]

 static _messageToRecord(message) {
        //check if a converter has already turned this message into a record
        if (message && typeof message.value === "object" &&
            message instanceof SinkRecord) {

            return message;
        }

        try {
            const record = new SinkRecord();

// fix in here
            const msgTemp = JSON.parse(message.value.toString());
            const msgValue = JSON.parse(msgTemp);

            record.kafkaOffset = message.offset;
            record.key = message.key;
            record.partition = message.partition;

            record.keySchema = msgValue.keySchema;
            record.timestamp = msgValue.timestamp;
            record.value = msgValue.value;
            record.valueSchema = msgValue.valueSchema;

            return record;
        } catch (error) {
            debug("Failed to turn message into sink record.", error.message);
            super.emit("error", "Failed to turn message into SinkRecord: " + error.message);
            return message;
        }
    }