Skip to content

G
goods
Commit bd87fc3e authored by mengweifu's avatar mengweifu
Browse files
Options

add:kafka

parent b92efa6c
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
application/services/common/KafkaService.php
View file @ bd87fc3e
...@@ -22,7 +22,7 @@ class KafkaService ...@@ -22,7 +22,7 @@ class KafkaService
$kafka = KafkaUtil::getInstance($serverName); $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)); FileLog::info(sprintf('kafka produce success serverName %s msg = %s', $serverName, $msg));
} }
else { 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