你能帮助我如何实现这个使用Kafka流？
场景：将订单数据的所有发票分组。在实时流媒体中，可能会延迟接收发票。所以我们想等20分钟把所有的发票分组后再加入。
示例：订单“x”有3张发票，预计将在20分钟内收到。
预期输出：订单和3张发票应作为输出主题中的单个数据提供。
我们有下面的拓扑结构来实现这一点。
我们分别有订单流和发票流
我们正在根据订单密钥对发票进行分组。我们设置了20分钟的摇窗时间
将订单数据与生成的发票组关联
将输出写入新主题
问题：步骤3未等待步骤2完成。加入收到订单后立即执行的操作。所以我们没有得到预期的产出。
我们尝试使用joinwindows实现同样的功能。但是由于连接窗口是滑动窗口，所以我们在输出主题中得到了重复的数据。
在上面的例子中，如果我们使用join窗口而不是tumbling窗口，我们将得到3个输出数据，订单分别有1个发票、2个发票和3个发票。
请帮助我解决这个问题或建议任何替代方法
代码段：

KTable<Windowed<String>, List<InvoiceList>> invoiceList= invoiceStream
                .groupByKey()
        .windowedBy(TimeWindows.of(Duration.ofSeconds(1200)))
                .aggregate(() -> new ArrayList<InvoiceList>(),
                        (key, newValue, agg) -> {
                            new KeyValue<>(key, agg.add(newValue));
                            return agg;
                        },
                        Materialized.as("invoice-list").with(Serdes.String(), new ArrayListSerde<InvoiceList>(AppSerdes.InvoiceList())))

KStream<String, Order> orderOutput=

                orderStream.join(invoiceList, Joiner);

        orderOutput.to(AppConfig.OutputTopic.OUTPUT_ORDER,Produced.with(Serdes.String(), AppSerdes.Order()));