|
@@ -106,7 +106,7 @@ class V1Action extends Action {
|
|
|
echo "No more messages; will wait for more".PHP_EOL;
|
|
|
break;
|
|
|
case RD_KAFKA_RESP_ERR__TIMED_OUT:
|
|
|
- $fileName = $localDir.'/HC_'.$createTime . '.dat';
|
|
|
+ $fileName = $localDir.'/HC_'.json_decode($message->payload)->mac.$createTime . '.dat';
|
|
|
$md5Res = $this->createRouteMD5file($fileName);
|
|
|
$timeFram = time();
|
|
|
$createTime = date('Ymd_His', $timeFram);
|