你可以试着用这种风格

public void runStartFromLatestOffsets() throws Exception {
        // 50 records written to each of 3 partitions before launching a latest-starting consuming job
        final int parallelism = 3;
        final int recordsInEachPartition = 50;

        // each partition will be written an extra 200 records
        final int extraRecordsInEachPartition = 200;

        // all already existing data in the topic, before the consuming topology has started, should be ignored
        final String topicName = writeSequence("testStartFromLatestOffsetsTopic", recordsInEachPartition, parallelism, 1);

        // the committed offsets should be ignored
        KafkaTestEnvironment.KafkaOffsetHandler kafkaOffsetHandler = kafkaServer.createOffsetHandler();
        kafkaOffsetHandler.setCommittedOffset(topicName, 0, 23);
        kafkaOffsetHandler.setCommittedOffset(topicName, 1, 31);
kafkaOffsetHandler.setCommittedOffset(topicName, 2, 43);

因此，首先，Kafka的所有事件都是不断读取的，进一步的窗口操作不会对其产生影响。当谈到内存不足时，有更多的事情要考虑。
通常情况下，并不是为一个窗口存储每个事件，而是为该事件存储一些聚合
每当窗口关闭时，相应的内存就会被释放。
更多关于kafka消费者如何与eventtime交互的信息（您可以在此处查看水印）