Commit 4a5995d9 authored by 孟维甫's avatar 孟维甫

Merge branch 'feature_jielong_native' into 'test'

add:kafka

See merge request bp/goods!31
parents 6c4f6a0d bd87fc3e
......@@ -22,7 +22,7 @@ class KafkaService
$kafka = KafkaUtil::getInstance($serverName);
if ($kafka->produce($msg)) {
if ($kafka->produce($msg, $marketingInfo['activityId'])) {
FileLog::info(sprintf('kafka produce success serverName %s msg = %s', $serverName, $msg));
}
else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment