如何使用Apache Kafka Streams查找最后一个跳跃窗口

import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.StreamsBuilder;
import org.apache.kafka.streams.StreamsConfig;
import org.apache.kafka.streams.kstream.KGroupedStream;
import org.apache.kafka.streams.kstream.KStream;
import org.apache.kafka.streams.kstream.TimeWindows;
import org.apache.kafka.streams.kstream.Windowed;
import org.apache.kafka.streams.kstream.WindowedSerdes;
import org.apache.kafka.streams.kstream.internals.TimeWindow;

import java.util.Properties;

public class KafkaStreamsExample {
    public static void main(String[] args) {
        // 设置 Kafka Streams 配置参数
        Properties props = new Properties();
        props.put(StreamsConfig.APPLICATION_ID_CONFIG, "kafka-streams-example");
        props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

        // 创建流构建器
        StreamsBuilder builder = new StreamsBuilder();

        // 创建输入流
        KStream<String, String> inputStream = builder.stream("input-topic");

        // 执行跳跃窗口操作
        KGroupedStream<Windowed<String>, String> windowedStream = inputStream
                .groupByKey()
                .windowedBy(TimeWindows.of(5000).advanceBy(1000))
                .reduce((value1, value2) -> value2);

        // 将结果写入输出流
        windowedStream.to("output-topic");

        // 创建 Kafka Streams 应用程序
        KafkaStreams streams = new KafkaStreams(builder.build(), props);

        // 启动应用程序
        streams.start();
    }
}