在Kafka Streams Processor API中是否有GlobalKTable
(在DSL API中(等价物,即是否有方法配置状态存储,使其状态为全局而不是分片?
我认为Topology#addGlobalStore就是您想要的。以下是KafkaStreamsTest 的使用示例