|
@@ -62,6 +62,9 @@ public class TianXiGPServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
MDC.put(MDC_DEVICEID, deviceId);
|
|
|
packageData.setDeviceId(deviceId);
|
|
|
//发送数据到kafka
|
|
|
+ // 因为原始解析发送的kafka topic 配置不统一,
|
|
|
+ // 此段代码是公用,故直接采用的直接发送
|
|
|
+ // 此处添加的时间 解析端不使用。参见解析端
|
|
|
final MsgHeader header = packageData.getMsgHeader();
|
|
|
if (Constants.MSG_TERMINAL_LOCATION_INFO_UPLOAD == header.getMsgId()) {
|
|
|
sendMsg2Kafka(byteMerger(dataByteArray, DateUtil.formatDate2String(new Date()).getBytes()), packageData.getDeviceId(), channel);
|