在Kafka中将客户端从负载均衡器重定向到合适的用户

如何解决在Kafka中将客户端从负载均衡器重定向到合适的用户

我正在一个个人项目中，我希望能够从生产者向最终用户发送一条消息。 每条消息将具有一个密钥，用于标识必须接收该消息的用户。
这是我想象的整体结构：

我无法弄清楚如何告诉负载平衡器，例如，每当具有键2的用户联系负载平衡器时，我们就必须与使用键2的使用者处理分区建立连接（可能是WebSocket）在他们之中。可能可以通过使用Kafka在必须为密钥分配分区时使用的相同技术，或者通过跟踪每个使用者管理的密钥来完成某些事情。

我不知道这是否可行，但是即使可行，我描述的技术也可能会使代码与体系结构过于耦合。

您能帮我解决这个问题吗？我不想将消息存储在远程数据存储上并从随机使用者中检索它们。我希望消费者只要与之建立连接就能够尽快为用户服务。如果没有与该用户的连接，那么我可以存储消息并在连接准备好时将其传递。

解决方法

我最终发现他们在Netflix上使用的Push Messaging技术很有用。诀窍是添加由Web服务器组成的另一级别的间接访问。每当新客户端连接到其中一台Web服务器时，元组 都会保存在外部数据存储中。当使用者需要将消息发送给具有该特定密钥的客户端时，它将在外部注册表中查找该消息以查找客户端连接的位置。找到消息后，它将消息发送到正确的Web服务器，该服务器将消息推送到客户端。