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()
ugh(...) to get a valid partitioning:
> >>
> >> KStream dataStream = builder.stream(...).map(...).through(...);
> >>
> >> Afterward, your join should work.
> >>
> >> -Matthias
> >>
> >>
> &
ption.
if (thisSourceNodes == null || otherSourceNodes == null)
throw new TopologyBuilderException(this.name + " and " +
other.name + " are not joinable");
The question is, how can I change the key without lose parent data in order
to perform a join with KTable after that?
