如何在Apache Kafka中进行扇出?

问题描述 投票:0回答:1

我需要向所有消费者发送消息,但是在确定谁应该收到此消息之前,如何使用Kafka进行操作?

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

apache-kafka apache-kafka-streams
1个回答
0
投票

Kafka使消费者和生产者脱钩,当您写入主题时,您不知道哪个消费者可以读取数据。

因此,在Kafka中,您永远不会“向消费者发送消息”,只需将消息写到主题中就可以了。

消费者只需阅读主题。

© www.soinside.com 2019 - 2024. All rights reserved.