桥接kafka，消息重发布到EMQX主题上，使用MQTTX接受到的消息topic不正确

[Rick]

kafka的消息如下：
{
“aid”: 4,
“data”: {
“responseInfo”: {
“interfaceName”: “FOTA_UpdateStatusResp”,
“requestId”: “123”,
“statusCode”: 0
}
},
“dataProtocolVersion”: “1”,
“deviceId”: “sfdsfxdd2r2we52ee”,
“encryption”: 0,
“errorCode”: 0,
“errorMessage”: “”,
“eventId”: “123”,
“mid”: 7,
“requestTime”: 1708419892335,
“source”: 3,
“vehicleId”: “1234567”,
“vid”: “1234567”
}

[t1ger]

你应该是需要在SQL中先把你需要的变量提取出来，比如：

SELECT
  payload.vid as vid
FROM
  …

你可以先用SQL Test测试验证下