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)
1条答案
按热度按时间bis0qfac1#
不能直接将kstream转换为globalktable,但可以直接创建一个;有关更详细的基础知识理解,请参阅kstreams。
用于创建globalktable;
将globalktable附加到处理器以访问它。