我们可以在apachekafka中将kstream转换为全局ktable吗?

but5z9lq  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(371)

我想在斯卡拉为Kafka工作。我想知道是否有可能将Kafka流转换成Kafka全球ktable?如果是,如何???

bis0qfac

bis0qfac1#

不能直接将kstream转换为globalktable,但可以直接创建一个;有关更详细的基础知识理解,请参阅kstreams。
用于创建globalktable;

val builder = new StreamsBuilder()
val globalMaterialized: Materialized[String, String, KeyValueStore[Bytes, Array[Byte]]] =
      Materialized.as("global_store_name").withKeySerde(Serdes.String).withValueSerde(Serdes.String)
builder.globalTable("topic_name", globalMaterialized)

将globalktable附加到处理器以访问它。

相关问题