io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer caused by too many data query

I did look at the similar questions, but in my case it's a bit difference. I assume that this exception caused by too many data query. I tried remove some data from my database and I got it work, but if I added more data this exception will be thrown again. I use graphql subscription query with mongodb. This is how I do the query.

@GrapQLSubscription
fun findAllEmployees(): Publisher<List<Employee>> {
  return employeeRepository.findAll()
                           .collectList()
                           .flatMap { produceGraphQlSubscription(it) }
}

So how do I resolve this issue ? I want to keep pagination as my final card. Are there any other way around like set webflux timeout or etc?