我有一个主题加入了Kafka Streams。
流分析数据并将结果放到另一个主题“建议”。
可以向一个或多个用户分配一个推荐。
如何在主题中存储推荐？通过键入分区user_id？
如果用户是百万，怎么办？
客户可以连接到流避免话题吗？
如何在主题中存储推荐？通过键入分区
user_id？
取决于您要实现的目标，消息的密钥应该是用于将消息分组到单个分区中的标识符。具有相同密钥的邮件将被放置在相同的分区中。
如果用户数为百万，该怎么办？
所以您的recommendations主题将具有N个分区，对吗？您决定使用user_id作为消息的键，以便将同一用户的所有建议插入同一分区，这绝对可以。
现在，我认为您在这里缺少的是，您不必在用户和分区之间创建1-1映射。