understanding of kafka streams stores. I have an aggregation step in my topology and I provide custom Materialized instance with inmemory and without logging data store
Materialized.as(Stores.inMemoryKeyValueStore("some name")(implicitly[KeySerde[A]], implicitly[ValueSerde[B]]).withLoggingDisabled()
Will serialization/deserialization take place in this case?
Есть примерчик кода?
Обсуждают сегодня