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