This commit is contained in:
2021-08-18 11:23:30 +08:00
parent effee75d57
commit f375eec0a0
+1 -1
View File
@@ -64,7 +64,7 @@ class KafkaClient
* @param bool $isAck
* @throws Exception
*/
public function dispatch(string $key, string|array $params, bool $isAck = false)
public function push(string $key, string|array $params, bool $isAck = false)
{
$this->sendMessage([$params], $key, $isAck);
}