有没有使用Spring cloud streams kafka-streams创建GlobalKTable的例子？

import org.apache.kafka.streams.kstream.GlobalKTable;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Processor;
import org.springframework.kafka.support.KafkaHeaders;
import org.springframework.messaging.handler.annotation.Header;

@EnableBinding(Processor.class)
public class GlobalKTableExample {

    @StreamListener(Processor.INPUT)
    public void process(@Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key, MyMessage message) {
        // 处理消息
    }

    @StreamListener(Processor.INPUT)
    public void processGlobalKTable(@Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key, MyGlobalMessage message) {
        // 处理GlobalKTable的消息
    }

    public interface Processor {
        String INPUT = "input";

        @Input(INPUT)
        KStream<?, ?> input();
    }

    public class MyMessage {
        // 消息内容
    }

    public class MyGlobalMessage {
        // GlobalKTable的消息内容
    }
}