apache-kafka - 如何使用带有 Smallrye 反应式消息（发射器）的 Kafka 向各种订阅者广播

Question

我正在开发一个应用程序，它使用发射器向另一个使用 Kafka 连接器的应用程序中的各种订阅者发送消息。但我的问题是消息只到达一个订阅者而不是所有订阅者。我已经用 mp.messaging.outgoing.channel.broadcast=true 配置了我的频道，并且我的发射器也用“@Broadcast”注释。所以它应该到达他们所有的订户。我不知道我是否需要配置其他东西。

谢谢。