我想写一个webman作为consumer的程序,该程序只负责接收并消费kafka的队列消息。
查阅文档看到了自定义非监听进程,我按照案例在process下面创建了文件,并在config/process中增加了新进程的配置。
class TaskTest
{
public function onWorkerStart()
{
dump('---------');
}
}
'task' => [
'handler' => process\TaskTest::class
],
当我启动webman进程后,似乎自定义的非监听进程并没有启动,cmd上没有输出,将dump换成别的操作也没有生效。
想问一下,该如何启动自定义非监听进程。
我的目的是根据kafka中的topic,一一对应创建自定义非监听进程,将消息同步至es中。
以下是我实际的代码
不可能,你肯定没按照文档来。而且dump是tp内置的,得用var_dump
感谢回复。您可以看我在问题描述中更新的图片,我是完全按照文档上一步步来的,只是替换了文档中的Db,改为了var_dump。
在windows中使用php windows.php启动
可以了。非常感谢!