diff --git a/app/controller/TestKafkaSend.php b/app/controller/TestKafkaSend.php index 454f05f..f06e651 100644 --- a/app/controller/TestKafkaSend.php +++ b/app/controller/TestKafkaSend.php @@ -100,6 +100,7 @@ class TestKafkaSend extends BaseController } else { // 获取当前taskId $taskId = Cache::inc('taskId'); + trace('taskId : '.$taskId,'test_consumer'); // 缓存taskId与消息ID Cache::set('taskId_'.$taskId,array($res['msgId'],$res['theme']), 300); $data_data = array('type' => $res['type'], 'taskId' => $taskId, 'wxid' => $res['wxid'], 'date' => time(), 'data' => isset($res['data'])?$res['data']:'', 'timeInMillis' => time());