diff --git a/consumer.go b/consumer.go
index 506e657f0..94b0b18ad 100644
--- a/consumer.go
+++ b/consumer.go
@@ -461,6 +461,7 @@ feederLoop:
 						child.messages <- msg
 					}
 					child.broker.input <- child
+					expiryTicker.Stop()
 					continue feederLoop
 				} else {
 					// current message has not been sent, return to select