Kafka

安装依赖:composer require usualtool/ut-kafka

Kafka在UT中用以实现主从数据库同步及消息队列服务扩展。

生产者
当产生数据变动时(update、del、insert)生产者端将发送消息到消费者端进行消费,再由消费者端自动进行数据的同步处理动作。
生产者发送消息示例

消费者
启动一个消费者监听:php usualtool kafka 服务器 主题名称
php usualtool kafka 192.168.0.1:9020 test
多个brokers可以使用用半角逗号分隔如:192.168.0.1:9020,192.168.0.2:9020

文档有错误?
反馈:292951110@qq.com

定位至目录

始于2018年,UT框架版权归原作者所有. 蜀ICP备09015842号-2 川公网安备51018202000023号
开放、包容、发展。 工单 | UT调试库 | Api | Teamwork | Contract | Team