Kafka有两条溪流:
流a:成对的[userid,country]
流b:成对的[docid,country]
我只需要知道一对的存在,这样值就可以 true/null
. 多个用户和多个文档可以共享多个国家,因此在这两种情况下关系都是多对多的。单个用户可以分配多个国家,单个单据可以分配多个国家。
我需要的是带有 true/null
值(这样我就可以在存储的下游添加或删除它们)。
我没有弄清楚的是,如何使用kafka的streamapi来实现这一点。我尝试过各种连接,但它们只在精确的密钥上工作(这对于分布式系统是有意义的),但感觉好像限制了我实现这一点。
暂无答案!
目前还没有任何答案,快来回答吧!