如何在处理器 API 中创建 GlobalKTable？
How to create GlobalKTable in the Processor API?
Kafka Streams Processor API 中是否有 GlobalKTable（在 DSL API 中）等价物 API 即是否有配置状态存储的方法，以便它们的状态是全局的而不是分片？
我认为 Topology#addGlobalStore 就是您要查找的内容。
这是 KafkaStreamsTest
中的示例用法
Kafka Streams Processor API 中是否有 GlobalKTable（在 DSL API 中）等价物 API 即是否有配置状态存储的方法，以便它们的状态是全局的而不是分片？
我认为 Topology#addGlobalStore 就是您要查找的内容。 这是 KafkaStreamsTest
中的示例用法