如何将特定数据分配给 Kafka 中的用户？
How to assign specific data to user in Kafka?
我有一些主题加入了 Kafka Streams。
流分析数据并将结果放入另一个主题"Recommendations"。
一个推荐可以分配给一个或多个用户。
如何在主题中存储推荐？在分区 user_id?
万一用户呢？
客户可以连接到流回避话题吗？
How to store recommendation in topic? By key in partition user_id?
根据您要实现的目标，消息的键应该是用于将消息分组到单个分区中的标识符。具有相同密钥的消息将被放置到相同的分区中。
What if users are million?
那么您的 recommendations 主题将有 N 个分区，对吗？您决定使用 user_id 作为消息的键，以便将同一用户的所有推荐插入到同一分区，这绝对没问题。
现在我认为您在这里缺少的是您不一定必须在用户和分区之间创建 1-1 映射。
我有一些主题加入了 Kafka Streams。
流分析数据并将结果放入另一个主题"Recommendations"。
一个推荐可以分配给一个或多个用户。
如何在主题中存储推荐？在分区
user_id? 中键入
万一用户呢？
客户可以连接到流回避话题吗？
How to store recommendation in topic? By key in partition
user_id?
根据您要实现的目标，消息的键应该是用于将消息分组到单个分区中的标识符。具有相同密钥的消息将被放置到相同的分区中。
What if users are million?
那么您的 recommendations 主题将有 N 个分区，对吗？您决定使用 user_id 作为消息的键，以便将同一用户的所有推荐插入到同一分区，这绝对没问题。
现在我认为您在这里缺少的是您不一定必须在用户和分区之间创建 1-1 映射。