如何在处理器API中创建GlobalKTable



在Kafka Streams Processor API中是否有GlobalKTable(在DSL API中(等价物,即是否有方法配置状态存储,使其状态为全局而不是分片?

我认为Topology#addGlobalStore就是您想要的。以下是KafkaStreamsTest 的使用示例

相关内容

  • 没有找到相关文章

最新更新