diff --git a/probe/docker/registry.go b/probe/docker/registry.go
index c9e06c73bc..f17653e7be 100644
--- a/probe/docker/registry.go
+++ b/probe/docker/registry.go
@@ -161,7 +161,11 @@ func (r *registry) listenForEvents() bool {
 	otherUpdates := time.Tick(r.interval)
 	for {
 		select {
-		case event := <-events:
+		case event, ok := <-events:
+			if !ok {
+				log.Errorf("docker registry: event listener unexpectedly disconnected")
+				return true
+			}
 			r.handleEvent(event)
 
 		case <-otherUpdates: