Hello Gaspar,
In your case, a single topic can have messages in different format, and my
guess is that they usually have different semantics (e.g. one format for
data record, and another format for control message / error log / etc).
In this case, I'd suggest similar solutions as you mentioned, t
Hi there,
my question is about Kafka Streams. I'm writting an application using
Streams. I read JSON from Kafka topic and I make some transformations.
I'm using
Serde jsonNodeSerder = Serdes.serdeFrom(new JsonSerializer(), new
JsonDeserializer());
KStream kStream = builder.stream(Serdes.String()
