我有一个symfony 5.4项目，我想用symfony messenger组件实现Kafka。
我已经看到了几种方法来做到这一点，包括这篇文章：Symfony Messenger with Apache Kafka as queue transport实现了4个捆绑包（都是必需的？），一个bundle https://github.com/KonstantinCodes/messenger-kafka，我不确定要实现什么最佳实践。在Symfony官方文档中，我只找到了这一行：https://symfony.com/doc/current/messenger.html#transports-async-queued-messages如果你有任何反馈，我很乐意听到它：）
1条答案
按热度按时间643ylb081#
以下是symfony/messenger文档中提供的内容：
如果你想使用不支持的传输，请查看Enqueue的传输，它支持Kafka和Google Pub/Sub等。
来源：https://symfony.com/doc/current/messenger.html#transports-async-queued-messages
所以，是的，你需要所有这些依赖关系。
所发生的是，您将symfony/messenger配置为使用enqueue驱动程序，该驱动程序在术语上使用Kafka。