Hi mates, I got some troubles with the implementation of integration tests for
the job, based on connected streams.
It has the following logic:
I got two streams, first one is a stream of rules, and another one is a stream
of events
to apply events on each rule, I’ve implemented a KeyedBroadcast
Hi mates, I got some troubles with the implementation of integration tests for
the job, based on connected streams.
It has the following logic:
I got two streams, first one is a stream of rules, and another one is a stream
of events
to apply events on each rule, I’ve implemented a KeyedBroadcast
