如何在 Apache Kafka 中进行扇出？

Question

我需要为所有消费者发送消息，但在检测谁应该收到此消息之前，如何使用 Kafka 来做到这一点？

我应该使用 Kafks 流来过滤数据然后发送给消费者吗？ 据我所知，每个消费者都应该添加到唯一的消费者组中，但是如何实时检测谁必须接收消息？

Answer 1

Kafka 将消费者和生产者解耦，当你写入一个主题时，你不知道哪些消费者可能会读取数据。

因此，在 Kafka 中你永远不会 "send a message to a consumer"，你只需将消息写入主题即可。

消费者只是阅读主题。