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