安装依赖：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