Streams - Manage Json SerDe error

2016-07-04 Thread Gaspar Muñoz
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 =

Re: Kafka Streams: KStream - KTable Left Join

2016-05-05 Thread Gaspar Muñoz
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

Kafka Streams: KStream - KTable Left Join

2016-05-04 Thread Gaspar Muñoz
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>*