messenger kafka:Symfony Messenger的简单Kafka传输 源码

Symfony Messenger卡夫卡运输 该捆绑包旨在为Symfony Messenger提供简单的Kafka传输。 Kafka REST代理支持即将推出。 安装 使用Symfony Flex的应用程序 打开命令控制台,输入项目目录并执行: $ composer require koco/messenger-kafka 不使用Symfony Flex的应用程序 添加了作曲家需求之后,通过将其添加到项目的config/bundles.php文件中已注册捆绑包的列表中来启用捆绑包: return [ // ... Koco \ Kafka \ KocoKafkaBundl