具有多对一映射的java kafka流左连接

Question

以前，左连接用作值joiner（请注意：joiner.apply（…））只返回一条记录，如下所示：

    KStream<String,Pair<String, Recipient>> joinedStream = aclInputStream
        .leftJoin(recipientTable,
                (recipientNotifyMsg,recipientDetail)->joiner.apply(recipientNotifyMsg,recipientDetail));

对于需求变更，此joiner。应用（…）返回记录列表。我很难做多对一映射来更改joiner的输出。应用（…）[这是一个列表]并推入连接流[需要单个值]。试图做一些事情，比如：

.leftJoin(recipientTable,
                (recipientNotifyMsg,recipientDetail)->{
                  List<Pair<String, Recipient>> list = joiner.apply(recipientNotifyMsg,recipientDetail);
                  list.forEach(pair -> return pair);
                });

我能在这里得到帮助吗