kafka message

www-api/app/Controllers/WrenchHooks.php

@@ -41,8 +41,12 @@ class WrenchHooks extends BaseController
 
         try {
             if ( $enable_event_publish ==  true  && !empty($in)  ){
+                $eventMsg = [
+                    "message" => serialize($in)
+                ];
+                
                 $local_url = "http://".$this->micro_service_net1.":".$microPort."/flutterOkHook";
-                $out = $this->APIcall('POST', $local_url, $in);
+                $out = $this->APIcall('POST', $local_url, $eventMsg);  //kafKa Lane
             }
         } catch (Exception $e) {
             log_message('critical', "WrenchHooks flutter Kafka fail => ".$e->getMessage());