Im processing a stream that needs to be transformed based on an inventory data. Inherently, the inventory data will be big (dont have exact figure) and will have A LOT of reads and very few writes.

Let’s assume I have 3 task managers with 1 slot for each.

How can my transform operator running on 3 different machines use an in-memory, replicated cache?