我需要向所有消费者发送消息,但是在确定谁应该收到此消息之前,如何使用Kafka进行操作?
我应该使用Kafks流过滤数据然后发送给消费者吗?据我了解,应该将每个消费者都添加到唯一的消费者组中,但是如何实时检测谁必须接收消息呢?
Kafka使消费者和生产者脱钩,当您写入主题时,您不知道哪个消费者可以读取数据。
因此,在Kafka中,您永远不会“向消费者发送消息”,只需将消息写到主题中就可以了。
消费者只需阅读主题。