Hi,

I have a question regarding the "Broadcast State Pattern".
My job consume two streams (kafka, rabbitmq), on one of the streams come a
lot of data and continuously[1]. On the other  very few and rarely[2]. I'm
using the Broadcast State pattern, because the stream[2] are updating data
which are required for stream[1].

Q1: Is the Broadcast State Pattern the right way?

As I mentioned above, the stream[2] provide data and "say" read additional
data from a database.

Q2: What is the best(the most efficient) way to request a database from the
processElement(...) function?

Many Thanks!
Marke

Reply via email to