From 42a7797a50d4ede24c38752c8b4c9279e399f673 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Thu, 30 May 2019 09:15:20 -0700 Subject: [PATCH] Add chunk and total bytes to slow consumer log Signed-off-by: Derek Collison --- server/client.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/client.go b/server/client.go index 2243440e..3489caf0 100644 --- a/server/client.go +++ b/server/client.go @@ -940,7 +940,8 @@ func (c *client) flushOutbound() bool { if sce { atomic.AddInt64(&srv.slowConsumers, 1) c.clearConnection(SlowConsumerWriteDeadline) - c.Noticef("Slow Consumer Detected: WriteDeadline of %v Exceeded", c.out.wdl) + c.Noticef("Slow Consumer Detected: WriteDeadline of %v exceeded with %d chunks of %d total bytes.", + c.out.wdl, len(cnb), attempted) } } else { c.clearConnection(WriteError)