I have a topology like this:

   +-----------> global-ktable +---------+
   |                                     |
   +                                     v
topic-1                                stream
   +                                     ^
   |                                     |
   +----> other stream +--> topic-2 +----+

IOW, a global ktable is built from topic-1. Meanwhile, "other stream"
transforms topic-1 to topic-2. Finally, "stream" operators on topic-2,
and as part of its logic, reads data from "global-ktable".

I am worried about the race condition present in "stream" between the
message showing up on topic-2, and the "get" from "global-ktable". Is
there a way, other than retrying the `get`, to avoid this race?

Regards,
Raman

Reply via email to