Archive
Posts Tagged ‘rxjava’
Using a ConnectableFlux to do background batching on elasticsearch
9 January 2020
Leave a comment
We have a Project Reactor application which is a bit brittle on refactorings. The load on our elasticsearch cluster is pretty high due to many single get/insert by id’s. Adding batch read by id was so much work that I was looking for a different solution. I eventually came up with a solution using a ConnectableFlux.
Jeroen van Wilgenburg's blog 