Hi, In my application I have names of internal topics like this: ss-session-application-KSTREAM-JOINOTHER-0000000059-store-changelog-0 ss-session-application-KSTREAM-JOINTHIS-0000000049-store-changelog-0 ss-session-application-KSTREAM-OUTEROTHER-0000000050-store-changelog-0 ss-session-application-KTABLE-MERGE-STATE-STORE-0000000061-changelog-0
Is it possible to set concrete names for these instead of say ** KSTREAM-JOINOTHER-0000000059-store** This way I can identify at what code in my DSL is responsible for data inside them. So far I have set names for: Grouped.with Materialized.as Joined.with This has helped me get concrete names at many places however still at some places I see arbitrary names. Also note that somehow this code works Materialized.with(new JSONSerde<K>(), new TupleJSONSerde<Pair<L, V>>()) But not: Materialized.as("d-l-i-store").withKeySerde(new JSONSerde<K>()).withValueSerde(new TupleJSONSerde<Pair<L, V>>()) The error I get is: Description Resource Path Location Type The method withKeySerde(Serde<Object>) in the type Materialized<Object,Object,StateStore> is not applicable for the arguments (JSONSerde<K>) I have my class class JSONSerde<T extends JSONSerdeCompatible> implements Serializer<T>, Deserializer<T>, Serde<T> { ...... } This is pretty much same as from kafka streams typed example. Thanks Sachin