modify

HttpServer/Events/OnPipeMessage.php

@@ -92,9 +92,7 @@ class OnPipeMessage extends Callback
     {
         [$topic, $rdMessage] = $message['body'];
 
-        $message['handler'][0]->setParams(new Struct($topic, $rdMessage));
+        call_user_func($message['handler'], new Struct($topic, $rdMessage));
-
-        call_user_func($message['handler']);
 
         return 'success';
     }

Kafka/ConsumerInterface.php

@@ -19,7 +19,4 @@ interface ConsumerInterface
     public function onHandler(Struct $struct): void;
 
 
-    public function setParams(...$params): void;
-
-
 }