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 =
write to an
> >> intermediate topic via .through(...) to get a valid partitioning:
> >>
> >> KStream dataStream = builder.stream(...).map(...).through(...);
> >>
> >> Afterward, your join should work.
> >>
> >> -Matthias
> >&g
ot;);
The question is, how can I change the key without lose parent data in order
to perform a join with KTable after that?
Thanks.
--
Gaspar Muñoz
Vía de las dos Castillas, 33, Ática 4, 3ª Planta
28224 Pozuelo de Alarcón, Madrid
Tel: +34 91 828 6473 // www.stratio.com // *@stratiobd
<https://twitter.com/StratioBD>*