apache-kafka - 使用 Kafka 进行一对一和群组消息传递

Question

由于 Kafka 具有基于主题的发布-订阅架构，我如何使用 Kafka 处理 Web 应用程序的一对一和组消息传递部分？
我正在使用 SpringBoot+Angular 堆栈和 Docker Kafka 服务器。

Answer 1

By One-to-One, I suppose you mean one producer and one consumer i.e. using at as a queue.

这对于 Kafka 来说当然是可能的。您可以让一个消费者订阅一个主题，并通过不给他们授权来限制其他人。见 Authorization in Kafka

请注意，一旦消息被消费，它不会被删除，而是被提交，以便同一个消费者不会再次消费它。

By Group Messaging, I suppose you mean one producer > multiple consumers or multiple-producer > multiple-consumers

这也是可能的，一个生产者可以向一个主题生产消息，多个消费者可以消费它们。

如果所有消费者都具有相同的组 id，那么组中的每个消费者都只会获得消息的一个子集。

如果他们有不同的组 ID，那么每个消费者都会收到所有消息。

多个生产者也可以生产同一个主题。

消费者也可以订阅多个主题。