diff --git a/servicetalk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/RoundRobinLoadBalancer.java b/servicetalk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/RoundRobinLoadBalancer.java index 365f5123ff..b998b3034b 100644 --- a/servicetalk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/RoundRobinLoadBalancer.java +++ b/servicetalk-loadbalancer/src/main/java/io/servicetalk/loadbalancer/RoundRobinLoadBalancer.java @@ -346,6 +346,7 @@ private static class Host implements A void markInactive() { @SuppressWarnings("unchecked") final List toRemove = connectionsUpdater.getAndSet(this, CLOSED_LIST); + LOGGER.debug("Closing {} connection(s) gracefully to inactive address: {}", toRemove.size(), address); for (C conn : toRemove) { conn.closeAsyncGracefully().subscribe(); }