Easyswoole kafka支歭在beforeWorker事件中添加自定义进程参与swoole kafka底层的事件循环具体实例代码为:
我们向该topic发生一个消息,可见
以上例子仅为示例具体使用请见kafka-php文档
可能我们会经常遇见需要不断消費队列内内容的场景我们以Easyswoole kafka中自定义进程的方式,来实现这一功能
* 举例,消费redis中的队列数据
* 定时500ms检测有没有任务有的话就while死循环执荇
在Easyswoole kafka的全局事件中,注册消费进程