StateConsumerImpl and LocalTopologyManagerImpl both submit tasks to the SemaphoreCompletionService. They drain these tasks, however they never check for any exceptions. This means if there is any kind of exception while running inside this completion service the exception is never displayed anywhere is is silently ignored.