如何在 scala 中为 kafka 打印全局 Ktable？

Question

我正在尝试了解 GlobalKtable 在 kafka 中的工作方式，为此我正在尝试编写示例代码。 我已经创建了 globalKtable 但我也想看到 我已经尝试过 peek 功能但它不可用，现在我正在尝试通过视图但它给出了编译时错误。

在scala中查看globalktable的写法是什么？

我试过的是

'''
 val genderGlobalTable: GlobalKTable[String, abc] = builder
        .globalTable(kafkaStreamConfig.getString("abc-topic"),
          Materialized.as("abcStore")
            .withKeySerde(stringSerde)
            .withValueSerde(abcSerde))
    
      implicit val streams: KafkaStreams = new KafkaStreams(builder.build(), properties)
    
      val view: ReadOnlyKeyValueStore[String, abc] = streams
        .store("abcStore", new QueryableStoreType[abc])

'''

Answer 1

您不能创建作为接口的QueryableStoreType 实例。相反，您需要使用工厂类QueryableStoreTypes（注意，名称是复数，而接口名称是单数）来获取您需要的类型。

对于GlobalKTable，您可以使用QueryableStoreTypes.keyValueStore()（或取决于您的Kafka Streams 版本，QueryableStoreTypes.timestampedKeyValueStore()）。