我们可以在Apache Kafka中将KStream转换为全局KTable吗？

问题描述

我正尝试在Scala中制作kafka流。我想知道是否有可能将kafka流转换为kafka全局ktable？ 如果是，怎么办？

解决方法

您不能将一个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附加到处理器以对其进行访问。