The issue is that the callback is running in the fixed executor and then also tries doing a blocking call inside the fixed executor here. So in an environment where number of worker threads <= number of shards, then the change callback for different replica sets happened roughly at the same time, all of them will be blocked waiting for a worker thread to be available (which are none, since all of them are waiting for the same thing)