我想寫一個webman作為consumer的程序,該程序只負責接收并消費kafka的隊列消息。
查閱文檔看到了自定義非監(jiān)聽進程,我按照案例在process下面創(chuàng)建了文件,并在config/process中增加了新進程的配置。
class TaskTest
{
public function onWorkerStart()
{
dump('---------');
}
}
'task' => [
'handler' => process\TaskTest::class
],
當我啟動webman進程后,似乎自定義的非監(jiān)聽進程并沒有啟動,cmd上沒有輸出,將dump換成別的操作也沒有生效。
想問一下,該如何啟動自定義非監(jiān)聽進程。
我的目的是根據(jù)kafka中的topic,一一對應(yīng)創(chuàng)建自定義非監(jiān)聽進程,將消息同步至es中。
以下是我實際的代碼